org.mobicents.smsc.slee.services.smpp.server.rx

Class RxSmppServerSbb

java.lang.Object

org.mobicents.smsc.slee.services.deliverysbb.DeliveryCommonSbb

org.mobicents.smsc.slee.services.smpp.server.rx.RxSmppServerSbb

All Implemented Interfaces:

javax.slee.Sbb

public abstract class RxSmppServerSbb
extends DeliveryCommonSbb
implements javax.slee.Sbb

Author:

amit bhayani, sergey vetyutnev

Field Summary

Fields

Modifier and Type	Field and Description
protected org.mobicents.protocols.ss7.map.api.MAPSmsTpduParameterFactory	mapSmsTpduParameterFactory
protected static int	MAX_MESSAGES_PER_STEP
protected org.restcomm.slee.resource.smpp.SmppSessions	smppServerSessions
protected org.restcomm.slee.resource.smpp.SmppTransactionACIFactory	smppServerTransactionACIFactory

Fields inherited from class org.mobicents.smsc.slee.services.deliverysbb.DeliveryCommonSbb

dlvIsInited, logger, MPROC_RATYPE_ID, persistence, sbbContext, scheduler, smscPropertiesManagement, timerFacility

Constructor Summary

Constructors

Constructor and Description
RxSmppServerSbb()

Method Summary

Methods

Modifier and Type	Method and Description
abstract void	fireDeliverSmRespChild(com.cloudhopper.smpp.pdu.DeliverSmResp event, javax.slee.ActivityContextInterface activity, javax.slee.Address address)
abstract void	firePduRequestTimeoutChild(PduRequestTimeout2 event, javax.slee.ActivityContextInterface aci, javax.slee.Address address)
abstract void	fireRecoverablePduExceptionChild(com.cloudhopper.smpp.type.RecoverablePduException event, javax.slee.ActivityContextInterface aci, javax.slee.Address address)
abstract void	fireSubmitSmRespChild(com.cloudhopper.smpp.pdu.SubmitSmResp event, javax.slee.ActivityContextInterface activity, javax.slee.Address address)
abstract org.mobicents.slee.ChildRelationExt	getRxSmppServerChildSbb()
void	onActivityEndEvent(javax.slee.ActivityEndEvent event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onDeliverSm(SmsSetEvent event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onDeliverSmResp(com.cloudhopper.smpp.pdu.DeliverSmResp event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onDeliverSmRespParent(com.cloudhopper.smpp.pdu.DeliverSmResp event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
protected void	onDeliveryTimeout(SmsSet smsSet, String reason)
void	onPduRequestTimeout(org.restcomm.slee.resource.smpp.PduRequestTimeout event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onPduRequestTimeoutParent(PduRequestTimeout2 event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onRecoverablePduException(com.cloudhopper.smpp.type.RecoverablePduException event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onRecoverablePduExceptionParent(com.cloudhopper.smpp.type.RecoverablePduException event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onServiceStartedEvent(javax.slee.serviceactivity.ServiceStartedEvent event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onSubmitSmResp(com.cloudhopper.smpp.pdu.SubmitSmResp event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
void	onSubmitSmRespParent(com.cloudhopper.smpp.pdu.SubmitSmResp event, javax.slee.ActivityContextInterface aci, javax.slee.EventContext eventContext)
protected byte[]	recodeShortMessage(int dataCoding, String msg, byte[] udhPart)
void	sbbLoad()
void	sbbStore()
void	setSbbContext(javax.slee.SbbContext sbbContext)

Methods inherited from class org.mobicents.smsc.slee.services.deliverysbb.DeliveryCommonSbb

addInitialMessageSet, addInitialMessageSet, applyMprocRulesOnFailure, applyMprocRulesOnImsiResponse, applyMprocRulesOnSuccess, calculateNewDueDelay, calculateNewDueTime, cancelDeliveryTimer, commitSendingPoolMsgCount, confirmMessageInSendingPool, createFailureLists, endDeliveryAfterValidityPeriod, endRegisterMessageInSendingPool, generateCDR, generateCDRs, generateFailureReceipts, generateIntermediateReceipts, generateSuccessReceipt, generateTemporaryFailureCDR, getCurrentMsgNum, getCurrentMsgNumValue, getDeliveryTimerID, getDlvIsEnded, getDlvIsInited, getMessageInSendingPool, getNextMessageReferenceNumber, getPendingRequestsList, getSchedulerActivityContextInterface, getSendingPoolMessageCount, getSmsSet, getTargetId, getTotalUnsentMessageCount, getUnconfirmedMessageCountInSendingPool, getUnsentMessage, isDeliveringEnded, isMessageConfirmedInSendingPool, markDeliveringIsEnded, obtainNextMessage, obtainNextMessagesSendingPool, onTimerEvent, postProcessPermFailures, postProcessRerouted, postProcessSucceeded, postProcessTempFailures, registerMessageInSendingPool, rescheduleDeliveryTimer, sbbActivate, sbbCreate, sbbExceptionThrown, sbbPassivate, sbbPostCreate, sbbRemove, sbbRolledBack, sendTransactionalResponseFailure, sendTransactionalResponseSuccess, setCurrentMsgNum, setDeliveryTimerID, setDlvIsEnded, setDlvIsInited, setPendingRequestsList, setTargetId, unsetSbbContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface javax.slee.Sbb

sbbActivate, sbbCreate, sbbExceptionThrown, sbbPassivate, sbbPostCreate, sbbRemove, sbbRolledBack, unsetSbbContext

Field Detail

MAX_MESSAGES_PER_STEP

protected static int MAX_MESSAGES_PER_STEP

smppServerTransactionACIFactory

protected org.restcomm.slee.resource.smpp.SmppTransactionACIFactory smppServerTransactionACIFactory

smppServerSessions

protected org.restcomm.slee.resource.smpp.SmppSessions smppServerSessions

mapSmsTpduParameterFactory

protected org.mobicents.protocols.ss7.map.api.MAPSmsTpduParameterFactory mapSmsTpduParameterFactory

Constructor Detail

RxSmppServerSbb

public RxSmppServerSbb()

Method Detail

setSbbContext

public void setSbbContext(javax.slee.SbbContext sbbContext)

Specified by:

setSbbContext in interface javax.slee.Sbb

Overrides:

setSbbContext in class DeliveryCommonSbb

sbbLoad

public void sbbLoad()

Specified by:

sbbLoad in interface javax.slee.Sbb

Overrides:

sbbLoad in class DeliveryCommonSbb

sbbStore

public void sbbStore()

Specified by:

sbbStore in interface javax.slee.Sbb

Overrides:

sbbStore in class DeliveryCommonSbb

onServiceStartedEvent

public void onServiceStartedEvent(javax.slee.serviceactivity.ServiceStartedEvent event,
                         javax.slee.ActivityContextInterface aci,
                         javax.slee.EventContext eventContext)

onActivityEndEvent

public void onActivityEndEvent(javax.slee.ActivityEndEvent event,
                      javax.slee.ActivityContextInterface aci,
                      javax.slee.EventContext eventContext)

onDeliverSm

public void onDeliverSm(SmsSetEvent event,
               javax.slee.ActivityContextInterface aci,
               javax.slee.EventContext eventContext)

onSubmitSmRespParent

public void onSubmitSmRespParent(com.cloudhopper.smpp.pdu.SubmitSmResp event,
                        javax.slee.ActivityContextInterface aci,
                        javax.slee.EventContext eventContext)

onDeliverSmRespParent

public void onDeliverSmRespParent(com.cloudhopper.smpp.pdu.DeliverSmResp event,
                         javax.slee.ActivityContextInterface aci,
                         javax.slee.EventContext eventContext)

onPduRequestTimeoutParent

public void onPduRequestTimeoutParent(PduRequestTimeout2 event,
                             javax.slee.ActivityContextInterface aci,
                             javax.slee.EventContext eventContext)

onRecoverablePduExceptionParent

public void onRecoverablePduExceptionParent(com.cloudhopper.smpp.type.RecoverablePduException event,
                                   javax.slee.ActivityContextInterface aci,
                                   javax.slee.EventContext eventContext)

onDeliverSmResp

public void onDeliverSmResp(com.cloudhopper.smpp.pdu.DeliverSmResp event,
                   javax.slee.ActivityContextInterface aci,
                   javax.slee.EventContext eventContext)

onSubmitSmResp

public void onSubmitSmResp(com.cloudhopper.smpp.pdu.SubmitSmResp event,
                  javax.slee.ActivityContextInterface aci,
                  javax.slee.EventContext eventContext)

onPduRequestTimeout

public void onPduRequestTimeout(org.restcomm.slee.resource.smpp.PduRequestTimeout event,
                       javax.slee.ActivityContextInterface aci,
                       javax.slee.EventContext eventContext)

onRecoverablePduException

public void onRecoverablePduException(com.cloudhopper.smpp.type.RecoverablePduException event,
                             javax.slee.ActivityContextInterface aci,
                             javax.slee.EventContext eventContext)

fireDeliverSmRespChild

public abstract void fireDeliverSmRespChild(com.cloudhopper.smpp.pdu.DeliverSmResp event,
                          javax.slee.ActivityContextInterface activity,
                          javax.slee.Address address)

fireSubmitSmRespChild

public abstract void fireSubmitSmRespChild(com.cloudhopper.smpp.pdu.SubmitSmResp event,
                         javax.slee.ActivityContextInterface activity,
                         javax.slee.Address address)

firePduRequestTimeoutChild

public abstract void firePduRequestTimeoutChild(PduRequestTimeout2 event,
                              javax.slee.ActivityContextInterface aci,
                              javax.slee.Address address)

fireRecoverablePduExceptionChild

public abstract void fireRecoverablePduExceptionChild(com.cloudhopper.smpp.type.RecoverablePduException event,
                                    javax.slee.ActivityContextInterface aci,
                                    javax.slee.Address address)

getRxSmppServerChildSbb

public abstract org.mobicents.slee.ChildRelationExt getRxSmppServerChildSbb()

recodeShortMessage

protected byte[] recodeShortMessage(int dataCoding,
                        String msg,
                        byte[] udhPart)

onDeliveryTimeout

protected void onDeliveryTimeout(SmsSet smsSet,
                     String reason)

Specified by:

onDeliveryTimeout in class DeliveryCommonSbb