oghamcloudhopper.it

Class ReuseSessionStrategyTest

java.lang.Object

oghamcloudhopper.it.ReuseSessionStrategyTest

All Implemented Interfaces:

Supplier<SessionStrategyTestHelper.TestContext>

public class ReuseSessionStrategyTest
extends Object
implements Supplier<SessionStrategyTestHelper.TestContext>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	ReuseSessionStrategyTest.ReuseSessionTestContext

Field Summary

Fields

Modifier and Type	Field and Description
(package private) List<com.cloudhopper.smpp.SmppSession>	allSessions
(package private) com.cloudhopper.smpp.SmppClient	client1
(package private) com.cloudhopper.smpp.SmppClient	client2
(package private) List<com.cloudhopper.smpp.SmppClient>	clients
LoggingTestRule	loggingRule
org.mockito.junit.MockitoRule	mockito
(package private) SmppClientSupplier	supplier

Constructor Summary

Constructors

Constructor and Description
ReuseSessionStrategyTest()

Method Summary

Modifier and Type	Method and Description
void	cleanup()
SessionStrategyTestHelper.TestContext	get()
void	reuseSession() ┌─────────┐ ┌─────────┐ │ Client │ │ Server │ └────┬────┘ └────┬────┘ │ ├─┐ start() │ │<┘ │ │ │ │ ├─┐ send(Sms(sms content 1 / session 1)) │ │<┘ │ │ connect [session 1] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ : : : wait for expiration of last request (200ms) : (?) expiration is configured to 100ms (=> need to send EnquireLink) : : │ │ │ │ ├─┐ send(Sms(sms content 2 / session 1)) │ │<┘ │ │ send EnquireLink │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ : : : wait for expiration of last request (200ms) : (?) expiration is configured to 100ms (=> need to send EnquireLink) : : │ │ │ │ ├─┐ send(Sms(sms content 3 / session 1)) │ │<┘ │ │ send EnquireLink │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤
void	reuseSessionButEnquireLinkTimeout() ┌─────────┐ ┌─────────┐ │ Client │ │ Server │ └────┬────┘ └────┬────┘ │ ├─┐ start() │ │<┘ │ │ │ │ ├─┐ send(Sms(sms content 1 / session 1)) │ │<┘ │ │ connect [session 1] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ : : : wait for expiration of last request (50ms) : (?) expiration is configured to 20ms : : │ │ │ │ ├─┐ send(Sms(sms content 2 / session 2)) │ │<┘ │ │ send EnquireLink │ ├─────────────────────────────────────────────>│ │ ├─┐ wait(300ms) ├─┐ timeout (100ms) │ │ │<┘ │ │ │ │ : │ │ │ unbind [session 1] │ ├─────────────────────────────────────────────>│ │ disconnected │ │<─────────────────────────────────────────────┤ │ │ │ connect [session 2] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤
void	reuseSessionButSendFailsDueToSessionClosedByServer() ┌─────────┐ ┌─────────┐ │ Client │ │ Server │ └────┬────┘ └────┬────┘ │ ├─┐ start() │ │<┘ │ │ │ │ ├─┐ send(Sms(sms content 1 / session 1)) │ │<┘ │ │ connect [session 1] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ ├─┐ stop() (?) session is closed by the server => need a new session │ │<┘ │ │ ├─┐ send(Sms(can't be sent)) │ │<┘ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ /!\ failure │ │<─────────────────────────────────────────────┤ │ │ ├─┐ closing [session 1] │ │<┘ │ │ unbind [session 1] │ ├─────────────────────────────────────────────>│ │ disconnected │ │<─────────────────────────────────────────────┤ │ │ : ├─┐ start() : │<┘ : wait for server ready │ : │ : │ ├─┐ send(Sms(sms content 2 / session 2)) │ │<┘ │ │ connect [session 2] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ │ │ ├─┐ wait(200ms) │ │<┘ : : : wait for expiration of last request (200ms) : (?) expiration is configured to 100ms (=> need to send EnquireLink) : : │ │ │ │ │ │ ├─┐ send(Sms(sms content 3 / session 2)) │ │<┘ │ │ send EnquireLink │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤
void	reuseSessionButSessionClosedByServer() ┌─────────┐ ┌─────────┐ │ Client │ │ Server │ └────┬────┘ └────┬────┘ │ ├─┐ start() │ │<┘ │ │ │ │ ├─┐ send(Sms(sms content 1 / session 1)) │ │<┘ │ │ connect [session 1] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ : : : wait for expiration of last request (200ms) : (?) expiration is configured to 100ms (=> need to send EnquireLink) : : │ │ │ │ ├─┐ send(Sms(sms content 2 / session 1)) │ │<┘ │ │ send EnquireLink │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ ├─┐ wait(200ms) │ │<┘ : : : wait for expiration of last request (200ms) : (?) expiration is configured to 100ms (=> need to send EnquireLink) : : │ │ │ │ : : : wait for reception of messages : : : │ │ │ ├─┐ stop() (?) session is closed by the server => need a new session │ │<┘ │ ├─┐ start() │ │<┘ │ │ ├─┐ send(Sms(sms content 3 / session 2)) │ │<┘ │ │ send EnquireLink │ ├─────────────────────────────────────────────>│ │ /!\ failure │ (?) ClosedChannelException │<─────────────────────────────────────────────┤ ├─┐ closing [session 1] │ │<┘ │ │ │ │ connect [session 2] │ ├─────────────────────────────────────────────>│ │ connected │ │<─────────────────────────────────────────────┤ │ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │ │ │ │ │ ├─┐ send(Sms(sms content 4 / session 2)) │ │<┘ │ │ │ │ send SubmitSm │ ├─────────────────────────────────────────────>│ │ response │ │<─────────────────────────────────────────────┤ │ │
void	setup()

Methods inherited from class java.lang.Object

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

Field Detail

loggingRule

public final LoggingTestRule loggingRule

mockito

public final org.mockito.junit.MockitoRule mockito

client1

@Spy
com.cloudhopper.smpp.SmppClient client1

client2

@Spy
com.cloudhopper.smpp.SmppClient client2

clients

List<com.cloudhopper.smpp.SmppClient> clients

allSessions

List<com.cloudhopper.smpp.SmppSession> allSessions

supplier

@Spy
SmppClientSupplier supplier

Constructor Detail

ReuseSessionStrategyTest

public ReuseSessionStrategyTest()

Method Detail

setup

public void setup()
           throws IOException

Throws:

IOException

cleanup

public void cleanup()
             throws SmppServerException

Throws:

SmppServerException

reuseSession

public void reuseSession()
                  throws Exception

  ┌─────────┐                                    ┌─────────┐
  │ Client  │                                    │ Server  │
  └────┬────┘                                    └────┬────┘
       │                                              ├─┐ start() 
       │                                              │<┘ 
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 1 / session 1))       │
       │<┘                                            │
       │ connect [session 1]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       :                                              :
       : wait for expiration of last request (200ms)  :                     (?) expiration is configured to 100ms (=> need to send EnquireLink)
       :                                              :
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 2 / session 1))       │
       │<┘                                            │
       │ send EnquireLink                             │
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       :                                              :
       : wait for expiration of last request (200ms)  :                     (?) expiration is configured to 100ms (=> need to send EnquireLink)
       :                                              :
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 3 / session 1))       │
       │<┘                                            │
       │ send EnquireLink                             │
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       
 

Throws:

Exception

reuseSessionButSessionClosedByServer

public void reuseSessionButSessionClosedByServer()
                                          throws Exception

  ┌─────────┐                                    ┌─────────┐
  │ Client  │                                    │ Server  │
  └────┬────┘                                    └────┬────┘
       │                                              ├─┐ start() 
       │                                              │<┘ 
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 1 / session 1))       │
       │<┘                                            │
       │ connect [session 1]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │
       :                                              :
       : wait for expiration of last request (200ms)  :                     (?) expiration is configured to 100ms (=> need to send EnquireLink)
       :                                              :
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 2 / session 1))       │
       │<┘                                            │
       │ send EnquireLink                             │
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              ├─┐ wait(200ms)
       │                                              │<┘ 
       :                                              :
       : wait for expiration of last request (200ms)  :                     (?) expiration is configured to 100ms (=> need to send EnquireLink)
       :                                              :
       │                                              │ 
       │                                              │ 
       :                                              :
       :       wait for reception of messages         :
       :                                              :
       │                                              │ 
       │                                              ├─┐ stop()            (?) session is closed by the server => need a new session
       │                                              │<┘ 
       │                                              ├─┐ start() 
       │                                              │<┘ 
       │                                              │ 
       ├─┐ send(Sms(sms content 3 / session 2))       │ 
       │<┘                                            │
       │ send EnquireLink                             │
       ├─────────────────────────────────────────────>│
       │                                 /!\ failure  │                     (?) ClosedChannelException 
       │<─────────────────────────────────────────────┤
       ├─┐ closing [session 1]                        │ 
       │<┘                                            │
       │                                              │ 
       │ connect [session 2]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 4 / session 2))       │
       │<┘                                            │
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       
 

Throws:

Exception

reuseSessionButEnquireLinkTimeout

public void reuseSessionButEnquireLinkTimeout()
                                       throws Exception

  ┌─────────┐                                    ┌─────────┐
  │ Client  │                                    │ Server  │
  └────┬────┘                                    └────┬────┘
       │                                              ├─┐ start() 
       │                                              │<┘ 
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 1 / session 1))       │
       │<┘                                            │
       │ connect [session 1]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       :                                              :
       :  wait for expiration of last request (50ms)  :           (?) expiration is configured to 20ms
       :                                              :
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 2 / session 2))       │
       │<┘                                            │
       │ send EnquireLink                             │
       ├─────────────────────────────────────────────>│
       │                                              ├─┐ wait(300ms) 
       ├─┐ timeout (100ms)                            │ │ 
       │<┘                                            │ │ 
       │                                              │ :
       │                                              │ 
       │ unbind [session 1]                           │
       ├─────────────────────────────────────────────>│
       │                                 disconnected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │ connect [session 2]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       
 

Throws:

Exception

reuseSessionButSendFailsDueToSessionClosedByServer

public void reuseSessionButSendFailsDueToSessionClosedByServer()
                                                        throws Exception

  ┌─────────┐                                    ┌─────────┐
  │ Client  │                                    │ Server  │
  └────┬────┘                                    └────┬────┘
       │                                              ├─┐ start() 
       │                                              │<┘ 
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 1 / session 1))       │
       │<┘                                            │
       │ connect [session 1]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │
       │                                              ├─┐ stop()            (?) session is closed by the server => need a new session
       │                                              │<┘ 
       │                                              │ 
       ├─┐ send(Sms(can't be sent))                   │
       │<┘                                            │
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                 /!\ failure  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       ├─┐ closing [session 1]                        │ 
       │<┘                                            │
       │ unbind [session 1]                           │
       ├─────────────────────────────────────────────>│
       │                                 disconnected │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       :                                              ├─┐ start() 
       :                                              │<┘ 
       :   wait for server ready                      │ 
       :                                              │ 
       :                                              │ 
       ├─┐ send(Sms(sms content 2 / session 2))       │ 
       │<┘                                            │
       │ connect [session 2]                          │
       ├─────────────────────────────────────────────>│
       │                                    connected │ 
       │<─────────────────────────────────────────────┤
       │                                              │
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │                                              │ 
       │                                              ├─┐ wait(200ms)
       │                                              │<┘ 
       :                                              :
       : wait for expiration of last request (200ms)  :                     (?) expiration is configured to 100ms (=> need to send EnquireLink)
       :                                              :
       │                                              │ 
       │                                              │ 
       │                                              │ 
       ├─┐ send(Sms(sms content 3 / session 2))       │
       │<┘                                            │
       │ send EnquireLink                             │
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       │                                              │ 
       │ send SubmitSm                                │ 
       ├─────────────────────────────────────────────>│
       │                                    response  │ 
       │<─────────────────────────────────────────────┤
       
 

Throws:

Exception

get

public SessionStrategyTestHelper.TestContext get()

Specified by:

get in interface Supplier<SessionStrategyTestHelper.TestContext>