org.jsmpp.examples
Class StressServer

java.lang.Object
  org.jsmpp.examples.StressServer

All Implemented Interfaces:

java.lang.Runnable, GenericMessageReceiverListener, ServerMessageReceiverListener

public class StressServer
extends java.lang.Object
implements java.lang.Runnable, ServerMessageReceiverListener

Author:

uudashr

Nested Class Summary

private class	StressServer.DeliveryReceiptTask
private class	StressServer.SessionStateListenerImpl
private class	StressServer.TrafficWatcherThread
private class	StressServer.WaitBindTask

Field Summary

private static java.lang.String	DEFAULT_LOG4J_PATH
private static int	DEFAULT_MAX_WAIT_BIND
private static java.lang.Integer	DEFAULT_PORT
private static java.lang.Integer	DEFAULT_PROCESSOR_DEGREE
private static org.slf4j.Logger	logger
private MessageIDGenerator	messageIDGenerator
private int	port
private int	processorDegree
private java.util.concurrent.atomic.AtomicInteger	requestCounter
private java.util.concurrent.ExecutorService	waitBindExecService

Constructor Summary

StressServer(int port, int processorDegree)

Method Summary

static void	main(java.lang.String[] args)
void	onAcceptCancelSm(CancelSm cancelSm, SMPPServerSession source)
DataSmResult	onAcceptDataSm(DataSm dataSm, Session source) Event that called when a data short message accepted.
QuerySmResult	onAcceptQuerySm(QuerySm querySm, SMPPServerSession source)
void	onAcceptReplaceSm(ReplaceSm replaceSm, SMPPServerSession source)
SubmitMultiResult	onAcceptSubmitMulti(SubmitMulti submitMulti, SMPPServerSession source)
MessageId	onAcceptSubmitSm(SubmitSm submitSm, SMPPServerSession source)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_WAIT_BIND

private static final int DEFAULT_MAX_WAIT_BIND

See Also:

Constant Field Values

DEFAULT_LOG4J_PATH

private static final java.lang.String DEFAULT_LOG4J_PATH

See Also:

Constant Field Values

DEFAULT_PORT

private static final java.lang.Integer DEFAULT_PORT

DEFAULT_PROCESSOR_DEGREE

private static final java.lang.Integer DEFAULT_PROCESSOR_DEGREE

logger

private static final org.slf4j.Logger logger

waitBindExecService

private final java.util.concurrent.ExecutorService waitBindExecService

messageIDGenerator

private final MessageIDGenerator messageIDGenerator

requestCounter

private final java.util.concurrent.atomic.AtomicInteger requestCounter

processorDegree

private int processorDegree

port

private int port

Constructor Detail

StressServer

public StressServer(int port,
                    int processorDegree)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

onAcceptQuerySm

public QuerySmResult onAcceptQuerySm(QuerySm querySm,
                                     SMPPServerSession source)
                              throws ProcessRequestException

Specified by:

onAcceptQuerySm in interface ServerMessageReceiverListener

Throws:

ProcessRequestException

onAcceptSubmitSm

public MessageId onAcceptSubmitSm(SubmitSm submitSm,
                                  SMPPServerSession source)
                           throws ProcessRequestException

Specified by:

onAcceptSubmitSm in interface ServerMessageReceiverListener

Throws:

ProcessRequestException

onAcceptSubmitMulti

public SubmitMultiResult onAcceptSubmitMulti(SubmitMulti submitMulti,
                                             SMPPServerSession source)
                                      throws ProcessRequestException

Specified by:

onAcceptSubmitMulti in interface ServerMessageReceiverListener

Throws:

ProcessRequestException

onAcceptDataSm

public DataSmResult onAcceptDataSm(DataSm dataSm,
                                   Session source)
                            throws ProcessRequestException

Description copied from interface: GenericMessageReceiverListener

Event that called when a data short message accepted.

Specified by:

onAcceptDataSm in interface GenericMessageReceiverListener

Parameters:

dataSm - is the data_sm command.

source - is the session receive the data_sm command.

Returns:

the data_sm result.

Throws:

ProcessRequestException - throw if there should be return non-ok command_status for the response.

onAcceptCancelSm

public void onAcceptCancelSm(CancelSm cancelSm,
                             SMPPServerSession source)
                      throws ProcessRequestException

Specified by:

onAcceptCancelSm in interface ServerMessageReceiverListener

Throws:

ProcessRequestException

onAcceptReplaceSm

public void onAcceptReplaceSm(ReplaceSm replaceSm,
                              SMPPServerSession source)
                       throws ProcessRequestException

Specified by:

onAcceptReplaceSm in interface ServerMessageReceiverListener

Throws:

ProcessRequestException

main

public static void main(java.lang.String[] args)