Package com.seleniumsoftware.SMPPSim
Class Smsc
- java.lang.Object
-
- com.seleniumsoftware.SMPPSim.Smsc
-
public class Smsc extends java.lang.Object
-
-
Field Summary
Fields Modifier and Type Field Description private longbindReceiverERRprivate longbindReceiverOKprivate longbindTransceiverERRprivate longbindTransceiverOKprivate longbindTransmitterERRprivate longbindTransmitterOKprivate static java.net.Socketcallbackprivate static booleancallback_server_onlineprivate static java.io.OutputStreamcallback_streamprivate longcancelSmERRprivate longcancelSmOKprivate StandardConnectionHandler[]connectionHandlersprivate java.net.ServerSocketcssprivate longdataSmERRprivate longdataSmOKprivate static booleandecodePdusprivate java.lang.ThreaddelayedInboundQueueThreadprivate longdeliverSmERRprivate longdeliverSmOKprivate java.lang.ThreaddeliveryServiceprivate DelayedDrQueuedrqprivate java.lang.Threaddrq_threadprivate MoServicedsprivate longenquireLinkERRprivate longenquireLinkOKprivate longgenericNakERRprivate longgenericNakOKprivate HttpHandler[]httpcontrollersprivate intinbound_queue_capacityprivate java.lang.ThreadinboundQueueServiceprivate InboundQueueiqprivate LifeCycleManagerlcmprivate java.lang.ThreadlifecycleServiceprivate static java.util.logging.Loggerloggerprivate static longmessage_idprivate OutboundQueueoq(package private) booleanoutbind_sentprivate longoutbindERRprivate longoutbindOKprivate intoutbound_queue_capacityprivate longquerySmERRprivate longquerySmOKprivate intreceiverIndexprivate longreplaceSmERRprivate longreplaceSmOKprivate booleanrunningprivate intrxBoundCountprivate static intsequence_noprivate java.io.FileOutputStreamsmeBinaryprivate java.io.FilesmeBinaryFileprivate java.io.FileWritersmeDecodedprivate java.io.FilesmeDecodedFileprivate java.net.ServerSocketsmpp_ssprivate java.io.FileOutputStreamsmppsimBinaryprivate java.io.FilesmppsimBinaryFileprivate java.io.FileWritersmppsimDecodedprivate java.io.FilesmppsimDecodedFileprivate static Smscsmscprivate static byte[]SMSC_SYSTEMIDprivate java.util.DatestartTimeprivate java.lang.StringstartTimeStringprivate longsubmitMultiERRprivate longsubmitMultiOKprivate longsubmitSmERRprivate longsubmitSmOKprivate inttrxBoundCountprivate inttxBoundCountprivate longunbindERRprivate longunbindOK
-
Constructor Summary
Constructors Modifier Constructor Description privateSmsc()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanauthenticate(java.lang.String systemid, java.lang.String password)private voidcallback(byte[] pdu, byte[] type)private intcancelMessages(int source_addr_ton, int source_addr_npi, java.lang.String source_addr, int dest_addr_ton, int dest_addr_npi, java.lang.String destination_addr)private intcancelMessages(java.lang.String service_type, int source_addr_ton, int source_addr_npi, java.lang.String source_addr, int dest_addr_ton, int dest_addr_npi, java.lang.String destination_addr)CancelSMRespcancelSm(CancelSM q, CancelSMResp r)voidconnectToCallbackServer(java.lang.Object mutex)voiddoEsmeToEsmeDelivery(SubmitSM smppmsg)voiddoLoopback(DataSM smppmsg)voiddoLoopback(SubmitSM smppmsg)longgetBindReceiverERR()longgetBindReceiverOK()longgetBindTransceiverERR()longgetBindTransceiverOK()longgetBindTransmitterERR()longgetBindTransmitterOK()static java.net.SocketgetCallback()static java.io.OutputStreamgetCallback_stream()longgetCancelSmERR()longgetCancelSmOK()java.net.ServerSocketgetCss()longgetDataSmERR()longgetDataSmOK()java.lang.ThreadgetDelayedInboundQueueThread()longgetDeliverSmERR()longgetDeliverSmOK()longgetEnquireLinkERR()longgetEnquireLinkOK()longgetGenericNakERR()longgetGenericNakOK()intgetInbound_queue_capacity()intgetInbound_queue_size()static SmscgetInstance()InboundQueuegetIq()LifeCycleManagergetLcm()static longgetMessage_id()static java.lang.StringgetMessageID()private intgetNextReceiverIndex()static intgetNextSequence_No()OutboundQueuegetOq()longgetOutbindERR()longgetOutbindOK()intgetOutbound_queue_capacity()intgetOutbound_queue_size()intgetPending_queue_size()longgetQuerySmERR()longgetQuerySmOK()intgetReceiverBoundCount()longgetReplaceSmERR()longgetReplaceSmOK()intgetRxBoundCount()static intgetSequence_no()static byte[]getSMSC_SYSTEMID()java.lang.StringgetStartTimeString()longgetSubmitMultiERR()longgetSubmitMultiOK()longgetSubmitSmERR()longgetSubmitSmOK()intgetTrxBoundCount()intgetTxBoundCount()longgetUnbindERR()longgetUnbindOK()voidincBindReceiverERR()voidincBindReceiverOK()voidincBindTransceiverERR()voidincBindTransceiverOK()voidincBindTransmitterERR()voidincBindTransmitterOK()voidincCancelSmERR()voidincCancelSmOK()voidincDataSmERR()voidincDataSmOK()voidincDeliverSmERR()voidincDeliverSmOK()voidincEnquireLinkERR()voidincEnquireLinkOK()voidincGenericNakERR()voidincGenericNakOK()voidincQuerySmERR()voidincQuerySmOK()voidincReplaceSmERR()voidincReplaceSmOK()voidincRxBoundCount()voidincSubmitMultiERR()voidincSubmitMultiOK()voidincSubmitSmERR()voidincSubmitSmOK()voidincTrxBoundCount()voidincTxBoundCount()voidincUnbindERR()voidincUnbindOK()static booleanisCallback_server_online()static booleanisDecodePdus()booleanisOutbind_sent()booleanisRunning()booleanisValidSystemId(java.lang.String systemid)voidoutbind()voidprepareDeliveryReceipt(SubmitSM smppmsg, java.lang.String messageID, byte state, int sub, int dlvrd, int err)byte[]processDeliveryReceipt(DeliveryReceipt smppmsg)QuerySMRespquerySm(QuerySM q, QuerySMResp r)voidreceived(byte[] pdu)voidreceiverUnbound()ReplaceSMRespreplaceSm(ReplaceSM q, ReplaceSMResp r)StandardConnectionHandlerselectReceiver(java.lang.String address)voidsent(byte[] pdu)static voidsetCallback(java.net.Socket callback)static voidsetCallback_server_online(boolean callback_server_online)static voidsetCallback_stream(java.io.OutputStream callback_stream)static voidsetDecodePdus(boolean b)voidsetDelayedInboundQueueThread(java.lang.Thread delayedInboundQueueThread)voidsetInbound_queue_capacity(int i)static voidsetMessage_id(long l)voidsetMoServiceRunning()voidsetOutbind_sent(boolean outbind_sent)voidsetOutbindERR(long outbindERR)voidsetOutbindOK(long outbindOK)voidsetOutbound_queue_capacity(int i)voidsetRunning(boolean running)voidsetRxBoundCount(int i)static voidsetSequence_no(int i)static voidsetSMSC_SYSTEMID(byte[] bs)voidsetTrxBoundCount(int i)voidsetTxBoundCount(int i)voidstart()voidstop()voidstopMoService()voidwriteBinarySme(byte[] request)voidwriteBinarySmppsim(byte[] response)voidwriteDecodedSme(java.lang.String request)voidwriteDecodedSmppsim(java.lang.String response)
-
-
-
Field Detail
-
smsc
private static Smsc smsc
-
running
private boolean running
-
callback
private static java.net.Socket callback
-
callback_stream
private static java.io.OutputStream callback_stream
-
callback_server_online
private static boolean callback_server_online
-
logger
private static java.util.logging.Logger logger
-
message_id
private static long message_id
-
sequence_no
private static int sequence_no
-
SMSC_SYSTEMID
private static byte[] SMSC_SYSTEMID
-
decodePdus
private static boolean decodePdus
-
receiverIndex
private int receiverIndex
-
connectionHandlers
private StandardConnectionHandler[] connectionHandlers
-
smpp_ss
private java.net.ServerSocket smpp_ss
-
httpcontrollers
private HttpHandler[] httpcontrollers
-
css
private java.net.ServerSocket css
-
ds
private MoService ds
-
deliveryService
private java.lang.Thread deliveryService
-
delayedInboundQueueThread
private java.lang.Thread delayedInboundQueueThread
-
iq
private InboundQueue iq
-
oq
private OutboundQueue oq
-
drq
private DelayedDrQueue drq
-
drq_thread
private java.lang.Thread drq_thread
-
lcm
private LifeCycleManager lcm
-
lifecycleService
private java.lang.Thread lifecycleService
-
inboundQueueService
private java.lang.Thread inboundQueueService
-
inbound_queue_capacity
private int inbound_queue_capacity
-
outbound_queue_capacity
private int outbound_queue_capacity
-
smeBinaryFile
private java.io.File smeBinaryFile
-
smeBinary
private java.io.FileOutputStream smeBinary
-
smppsimBinaryFile
private java.io.File smppsimBinaryFile
-
smppsimBinary
private java.io.FileOutputStream smppsimBinary
-
smeDecodedFile
private java.io.File smeDecodedFile
-
smeDecoded
private java.io.FileWriter smeDecoded
-
smppsimDecodedFile
private java.io.File smppsimDecodedFile
-
smppsimDecoded
private java.io.FileWriter smppsimDecoded
-
startTime
private java.util.Date startTime
-
startTimeString
private java.lang.String startTimeString
-
txBoundCount
private int txBoundCount
-
rxBoundCount
private int rxBoundCount
-
trxBoundCount
private int trxBoundCount
-
bindTransmitterOK
private long bindTransmitterOK
-
bindTransceiverOK
private long bindTransceiverOK
-
bindReceiverOK
private long bindReceiverOK
-
bindTransmitterERR
private long bindTransmitterERR
-
bindTransceiverERR
private long bindTransceiverERR
-
bindReceiverERR
private long bindReceiverERR
-
submitSmOK
private long submitSmOK
-
submitSmERR
private long submitSmERR
-
submitMultiOK
private long submitMultiOK
-
submitMultiERR
private long submitMultiERR
-
deliverSmOK
private long deliverSmOK
-
deliverSmERR
private long deliverSmERR
-
querySmOK
private long querySmOK
-
querySmERR
private long querySmERR
-
cancelSmOK
private long cancelSmOK
-
cancelSmERR
private long cancelSmERR
-
replaceSmOK
private long replaceSmOK
-
replaceSmERR
private long replaceSmERR
-
enquireLinkOK
private long enquireLinkOK
-
enquireLinkERR
private long enquireLinkERR
-
unbindOK
private long unbindOK
-
unbindERR
private long unbindERR
-
genericNakOK
private long genericNakOK
-
genericNakERR
private long genericNakERR
-
dataSmOK
private long dataSmOK
-
dataSmERR
private long dataSmERR
-
outbindOK
private long outbindOK
-
outbindERR
private long outbindERR
-
outbind_sent
boolean outbind_sent
-
-
Method Detail
-
getInstance
public static Smsc getInstance()
-
start
public void start() throws java.lang.Exception- Throws:
java.lang.Exception
-
authenticate
public boolean authenticate(java.lang.String systemid, java.lang.String password)
-
isValidSystemId
public boolean isValidSystemId(java.lang.String systemid)
-
connectToCallbackServer
public void connectToCallbackServer(java.lang.Object mutex)
-
getMessageID
public static java.lang.String getMessageID()
-
getNextSequence_No
public static int getNextSequence_No()
-
querySm
public QuerySMResp querySm(QuerySM q, QuerySMResp r) throws MessageStateNotFoundException
- Throws:
MessageStateNotFoundException
-
cancelSm
public CancelSMResp cancelSm(CancelSM q, CancelSMResp r) throws MessageStateNotFoundException, InternalException
-
cancelMessages
private int cancelMessages(java.lang.String service_type, int source_addr_ton, int source_addr_npi, java.lang.String source_addr, int dest_addr_ton, int dest_addr_npi, java.lang.String destination_addr)
-
cancelMessages
private int cancelMessages(int source_addr_ton, int source_addr_npi, java.lang.String source_addr, int dest_addr_ton, int dest_addr_npi, java.lang.String destination_addr)
-
replaceSm
public ReplaceSMResp replaceSm(ReplaceSM q, ReplaceSMResp r) throws MessageStateNotFoundException
- Throws:
MessageStateNotFoundException
-
receiverUnbound
public void receiverUnbound()
-
getReceiverBoundCount
public int getReceiverBoundCount()
-
selectReceiver
public StandardConnectionHandler selectReceiver(java.lang.String address)
-
doLoopback
public void doLoopback(SubmitSM smppmsg) throws InboundQueueFullException
- Throws:
InboundQueueFullException
-
doLoopback
public void doLoopback(DataSM smppmsg) throws InboundQueueFullException
- Throws:
InboundQueueFullException
-
doEsmeToEsmeDelivery
public void doEsmeToEsmeDelivery(SubmitSM smppmsg) throws InboundQueueFullException
- Throws:
InboundQueueFullException
-
outbind
public void outbind()
-
prepareDeliveryReceipt
public void prepareDeliveryReceipt(SubmitSM smppmsg, java.lang.String messageID, byte state, int sub, int dlvrd, int err)
-
getNextReceiverIndex
private int getNextReceiverIndex()
-
processDeliveryReceipt
public byte[] processDeliveryReceipt(DeliveryReceipt smppmsg) throws java.lang.Exception
- Throws:
java.lang.Exception
-
setMoServiceRunning
public void setMoServiceRunning()
-
stopMoService
public void stopMoService()
-
stop
public void stop()
-
writeBinarySme
public void writeBinarySme(byte[] request) throws java.io.IOException- Throws:
java.io.IOException
-
writeBinarySmppsim
public void writeBinarySmppsim(byte[] response) throws java.io.IOException- Throws:
java.io.IOException
-
writeDecodedSme
public void writeDecodedSme(java.lang.String request) throws java.io.IOException- Throws:
java.io.IOException
-
writeDecodedSmppsim
public void writeDecodedSmppsim(java.lang.String response) throws java.io.IOException- Throws:
java.io.IOException
-
getSMSC_SYSTEMID
public static byte[] getSMSC_SYSTEMID()
- Returns:
-
setSMSC_SYSTEMID
public static void setSMSC_SYSTEMID(byte[] bs)
- Parameters:
bs-
-
getMessage_id
public static long getMessage_id()
- Returns:
-
getSequence_no
public static int getSequence_no()
- Returns:
-
setMessage_id
public static void setMessage_id(long l)
- Parameters:
l-
-
setSequence_no
public static void setSequence_no(int i)
- Parameters:
i-
-
getCss
public java.net.ServerSocket getCss()
- Returns:
-
isDecodePdus
public static boolean isDecodePdus()
- Returns:
-
setDecodePdus
public static void setDecodePdus(boolean b)
- Parameters:
b-
-
getIq
public InboundQueue getIq()
- Returns:
-
getOq
public OutboundQueue getOq()
- Returns:
-
getInbound_queue_capacity
public int getInbound_queue_capacity()
- Returns:
-
getInbound_queue_size
public int getInbound_queue_size()
- Returns:
-
getPending_queue_size
public int getPending_queue_size()
-
getOutbound_queue_capacity
public int getOutbound_queue_capacity()
- Returns:
-
getOutbound_queue_size
public int getOutbound_queue_size()
- Returns:
-
setInbound_queue_capacity
public void setInbound_queue_capacity(int i)
- Parameters:
i-
-
setOutbound_queue_capacity
public void setOutbound_queue_capacity(int i)
- Parameters:
i-
-
getLcm
public LifeCycleManager getLcm()
- Returns:
-
getStartTimeString
public java.lang.String getStartTimeString()
- Returns:
-
getRxBoundCount
public int getRxBoundCount()
- Returns:
-
getTrxBoundCount
public int getTrxBoundCount()
- Returns:
-
getTxBoundCount
public int getTxBoundCount()
- Returns:
-
setRxBoundCount
public void setRxBoundCount(int i)
- Parameters:
i-
-
setTrxBoundCount
public void setTrxBoundCount(int i)
- Parameters:
i-
-
setTxBoundCount
public void setTxBoundCount(int i)
- Parameters:
i-
-
incTxBoundCount
public void incTxBoundCount()
-
incRxBoundCount
public void incRxBoundCount()
-
incTrxBoundCount
public void incTrxBoundCount()
-
incBindTransmitterOK
public void incBindTransmitterOK()
-
incBindTransmitterERR
public void incBindTransmitterERR()
-
incBindTransceiverOK
public void incBindTransceiverOK()
-
incBindTransceiverERR
public void incBindTransceiverERR()
-
incBindReceiverOK
public void incBindReceiverOK()
-
incBindReceiverERR
public void incBindReceiverERR()
-
incSubmitSmOK
public void incSubmitSmOK()
-
incSubmitSmERR
public void incSubmitSmERR()
-
incSubmitMultiOK
public void incSubmitMultiOK()
-
incSubmitMultiERR
public void incSubmitMultiERR()
-
incDeliverSmOK
public void incDeliverSmOK()
-
incDeliverSmERR
public void incDeliverSmERR()
-
incQuerySmOK
public void incQuerySmOK()
-
incQuerySmERR
public void incQuerySmERR()
-
incCancelSmOK
public void incCancelSmOK()
-
incCancelSmERR
public void incCancelSmERR()
-
incReplaceSmOK
public void incReplaceSmOK()
-
incReplaceSmERR
public void incReplaceSmERR()
-
incDataSmOK
public void incDataSmOK()
-
incDataSmERR
public void incDataSmERR()
-
incEnquireLinkOK
public void incEnquireLinkOK()
-
incEnquireLinkERR
public void incEnquireLinkERR()
-
incUnbindOK
public void incUnbindOK()
-
incUnbindERR
public void incUnbindERR()
-
incGenericNakOK
public void incGenericNakOK()
-
incGenericNakERR
public void incGenericNakERR()
-
getBindReceiverERR
public long getBindReceiverERR()
- Returns:
-
getBindReceiverOK
public long getBindReceiverOK()
- Returns:
-
getBindTransceiverERR
public long getBindTransceiverERR()
- Returns:
-
getBindTransceiverOK
public long getBindTransceiverOK()
- Returns:
-
getBindTransmitterERR
public long getBindTransmitterERR()
- Returns:
-
getBindTransmitterOK
public long getBindTransmitterOK()
- Returns:
-
getCancelSmERR
public long getCancelSmERR()
- Returns:
-
getCancelSmOK
public long getCancelSmOK()
- Returns:
-
getDeliverSmERR
public long getDeliverSmERR()
- Returns:
-
getDeliverSmOK
public long getDeliverSmOK()
- Returns:
-
getEnquireLinkERR
public long getEnquireLinkERR()
- Returns:
-
getEnquireLinkOK
public long getEnquireLinkOK()
- Returns:
-
getGenericNakERR
public long getGenericNakERR()
- Returns:
-
getGenericNakOK
public long getGenericNakOK()
- Returns:
-
getQuerySmERR
public long getQuerySmERR()
- Returns:
-
getQuerySmOK
public long getQuerySmOK()
- Returns:
-
getReplaceSmERR
public long getReplaceSmERR()
- Returns:
-
getReplaceSmOK
public long getReplaceSmOK()
- Returns:
-
getSubmitMultiERR
public long getSubmitMultiERR()
- Returns:
-
getSubmitMultiOK
public long getSubmitMultiOK()
- Returns:
-
getSubmitSmERR
public long getSubmitSmERR()
- Returns:
-
getSubmitSmOK
public long getSubmitSmOK()
- Returns:
-
getDataSmERR
public long getDataSmERR()
- Returns:
-
getDataSmOK
public long getDataSmOK()
- Returns:
-
getUnbindERR
public long getUnbindERR()
- Returns:
-
getUnbindOK
public long getUnbindOK()
- Returns:
-
sent
public void sent(byte[] pdu)
-
received
public void received(byte[] pdu)
-
callback
private void callback(byte[] pdu, byte[] type)
-
isCallback_server_online
public static boolean isCallback_server_online()
-
setCallback_server_online
public static void setCallback_server_online(boolean callback_server_online)
-
getCallback
public static java.net.Socket getCallback()
-
setCallback
public static void setCallback(java.net.Socket callback)
-
getCallback_stream
public static java.io.OutputStream getCallback_stream()
-
setCallback_stream
public static void setCallback_stream(java.io.OutputStream callback_stream)
-
isOutbind_sent
public boolean isOutbind_sent()
-
setOutbind_sent
public void setOutbind_sent(boolean outbind_sent)
-
getOutbindERR
public long getOutbindERR()
-
setOutbindERR
public void setOutbindERR(long outbindERR)
-
getOutbindOK
public long getOutbindOK()
-
setOutbindOK
public void setOutbindOK(long outbindOK)
-
isRunning
public boolean isRunning()
-
setRunning
public void setRunning(boolean running)
-
getDelayedInboundQueueThread
public java.lang.Thread getDelayedInboundQueueThread()
-
setDelayedInboundQueueThread
public void setDelayedInboundQueueThread(java.lang.Thread delayedInboundQueueThread)
-
-