test_class.declarator: logger = LoggerFactory.getLogger(TestTCPIPClient.class)
test_class.modifier: private static final
test_class.original_string: private static final Logger logger = LoggerFactory.getLogger(TestTCPIPClient.class);
test_class.type: Logger
test_class.var_name: logger
test_class.declarator: LOGIN_TIMEOUT = 500*2
test_class.modifier: private static final
test_class.original_string: private static final int LOGIN_TIMEOUT = 500*2;
test_class.type: int
test_class.var_name: LOGIN_TIMEOUT
test_class.declarator: WAITING_TIMEOUT = 500*2
test_class.modifier: private static final
test_class.original_string: private static final int WAITING_TIMEOUT = 500*2;
test_class.type: int
test_class.var_name: WAITING_TIMEOUT
test_class.file: BackEnd/Service/service-tcpip/src/test/java/com/exactpro/sf/services/tcpip/TestTCPIPClient.java
test_class.identifier: TestTCPIPClient
test_class.superclass: extends TestTCPIPClientBase
test_case.body: @Test
      public void testConnection() throws Exception {
          logger.info("start testConnection()");
          try {
              startServices(LOGIN_TIMEOUT);
              Assert.assertTrue(client.isConnected());
  
              IMessage msg = DefaultMessageFactory.getFactory().createMessage(TCPIPMessageHelper.INCOMING_MESSAGE_NAME_AND_NAMESPACE, TCPIPMessageHelper.INCOMING_MESSAGE_NAME_AND_NAMESPACE);
              msg.addField("MessageType", 123);
              msg.addField("Qty", 123.123);
              msg.addField("ClOrdID", "");
  
              client.getSession().send(msg);
  
              if (logger.isDebugEnabled()) {
                  logger.debug("start to waiting messages on server; {} millisec", WAITING_TIMEOUT);
              }
              Pair<IMessage, ComparisonResult> result = waitMessage(server, msg, WAITING_TIMEOUT, ServiceHandlerRoute.FROM_APP, dictionaryName);
              ComparisonResult comparison=result.getSecond();
              Assert.assertEquals("Status of comparison isn't " + StatusType.PASSED + "; see: \n" + comparison, StatusType.PASSED,
                      comparison.getStatus());
              if (logger.isDebugEnabled()) {
                  logger.debug("end to waiting messages on server. Result: {} messages found", result.getFirst());
              }
  
              for (IoSession session:server.getSessionMap().keySet()){
                  session.write(msg);
              }
  
              if (logger.isDebugEnabled()) {
                  logger.debug("start to waiting messages on client; {} millisec", WAITING_TIMEOUT);
              }
              result = waitMessage(client, msg, WAITING_TIMEOUT, ServiceHandlerRoute.FROM_APP, dictionaryName);
              comparison = result.getSecond();
              Assert.assertEquals("Status of comparison isn't " + StatusType.PASSED + "; see: \n" + comparison, StatusType.PASSED,
                      comparison.getStatus());
              if (logger.isDebugEnabled()) {
                  logger.debug("end to waiting messages on client. Result: {} messages found", result.getFirst());
              }
          } catch (Exception e) {
              logger.error(e.getMessage(), e);
              throw e;
          } finally {
              logger.info("end testConnection()");
              client.dispose();
              Assert.assertEquals(ServiceStatus.DISPOSED, client.getStatus());
          }
      }
test_case.class_method_signature: TestTCPIPClient.testConnection()
test_case.full_signature: @Test public void testConnection()
test_case.identifier: testConnection
test_case.invocations: info startServices assertTrue isConnected createMessage getFactory addField addField addField send getSession isDebugEnabled debug waitMessage getSecond assertEquals getStatus isDebugEnabled debug getFirst keySet getSessionMap write isDebugEnabled debug waitMessage getSecond assertEquals getStatus isDebugEnabled debug getFirst error getMessage info dispose assertEquals getStatus
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testConnection()
focal_class.declarator: codecClass
focal_class.modifier: private
focal_class.original_string: private Class<? extends AbstractCodec> codecClass;
focal_class.type: Class<? extends AbstractCodec>
focal_class.var_name: codecClass
focal_class.declarator: fieldConverter
focal_class.modifier: private
focal_class.original_string: private IFieldConverter fieldConverter;
focal_class.type: IFieldConverter
focal_class.var_name: fieldConverter
focal_class.declarator: dataManager
focal_class.modifier: protected
focal_class.original_string: protected IDataManager dataManager;
focal_class.type: IDataManager
focal_class.var_name: dataManager
focal_class.file: BackEnd/Service/service-tcpip/src/main/java/com/exactpro/sf/services/tcpip/TCPIPClient.java
focal_class.identifier: TCPIPClient
focal_class.class_method_signature: TCPIPClient.internalInit()
focal_class.full_signature: @Override protected void internalInit()
focal_class.identifier: internalInit
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void internalInit()
focal_class.class_method_signature: TCPIPClient.internalStart()
focal_class.full_signature: @Override protected void internalStart()
focal_class.identifier: internalStart
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void internalStart()
focal_class.class_method_signature: TCPIPClient.initFilterChain(DefaultIoFilterChainBuilder filterChain)
focal_class.full_signature: @Override protected void initFilterChain(DefaultIoFilterChainBuilder filterChain)
focal_class.identifier: initFilterChain
focal_class.modifiers: @Override protected
focal_class.parameters: (DefaultIoFilterChainBuilder filterChain)
focal_class.return: void
focal_class.signature: void initFilterChain(DefaultIoFilterChainBuilder filterChain)
focal_class.class_method_signature: TCPIPClient.getSession()
focal_class.full_signature: @Override public TCPIPSession getSession()
focal_class.identifier: getSession
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: TCPIPSession
focal_class.signature: TCPIPSession getSession()
focal_class.class_method_signature: TCPIPClient.sendMessage(IMessage message, long timeOut)
focal_class.full_signature: @Deprecated public boolean sendMessage(IMessage message, long timeOut)
focal_class.identifier: sendMessage
focal_class.modifiers: @Deprecated public
focal_class.parameters: (IMessage message, long timeOut)
focal_class.return: boolean
focal_class.signature: boolean sendMessage(IMessage message, long timeOut)
focal_class.class_method_signature: TCPIPClient.sessionCreated(IoSession session)
focal_class.full_signature: @Override public void sessionCreated(IoSession session)
focal_class.identifier: sessionCreated
focal_class.modifiers: @Override public
focal_class.parameters: (IoSession session)
focal_class.return: void
focal_class.signature: void sessionCreated(IoSession session)
focal_class.class_method_signature: TCPIPClient.sessionClosed(IoSession session)
focal_class.full_signature: @Override public void sessionClosed(IoSession session)
focal_class.identifier: sessionClosed
focal_class.modifiers: @Override public
focal_class.parameters: (IoSession session)
focal_class.return: void
focal_class.signature: void sessionClosed(IoSession session)
focal_class.class_method_signature: TCPIPClient.exceptionCaught(IoSession session, Throwable cause)
focal_class.full_signature: @Override public void exceptionCaught(IoSession session, Throwable cause)
focal_class.identifier: exceptionCaught
focal_class.modifiers: @Override public
focal_class.parameters: (IoSession session, Throwable cause)
focal_class.return: void
focal_class.signature: void exceptionCaught(IoSession session, Throwable cause)
focal_class.class_method_signature: TCPIPClient.getSettings()
focal_class.full_signature: @Override public TCPIPSettings getSettings()
focal_class.identifier: getSettings
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: TCPIPSettings
focal_class.signature: TCPIPSettings getSettings()
focal_class.class_method_signature: TCPIPClient.getFieldConverter()
focal_class.full_signature: public IFieldConverter getFieldConverter()
focal_class.identifier: getFieldConverter
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: IFieldConverter
focal_class.signature: IFieldConverter getFieldConverter()
focal_class.class_method_signature: TCPIPClient.receive(IActionContext actionContext, IMessage msg)
focal_class.full_signature: @Override public IMessage receive(IActionContext actionContext, IMessage msg)
focal_class.identifier: receive
focal_class.modifiers: @Override public
focal_class.parameters: (IActionContext actionContext, IMessage msg)
focal_class.return: IMessage
focal_class.signature: IMessage receive(IActionContext actionContext, IMessage msg)
focal_class.class_method_signature: TCPIPClient.createSession(IoSession session)
focal_class.full_signature: @Override protected TCPIPSession createSession(IoSession session)
focal_class.identifier: createSession
focal_class.modifiers: @Override protected
focal_class.parameters: (IoSession session)
focal_class.return: TCPIPSession
focal_class.signature: TCPIPSession createSession(IoSession session)
focal_class.class_method_signature: TCPIPClient.getHumanReadable(IMessage message)
focal_class.full_signature: @Override protected String getHumanReadable(IMessage message)
focal_class.identifier: getHumanReadable
focal_class.modifiers: @Override protected
focal_class.parameters: (IMessage message)
focal_class.return: String
focal_class.signature: String getHumanReadable(IMessage message)
focal_class.class_method_signature: TCPIPClient.getHostname()
focal_class.full_signature: @Override protected String getHostname()
focal_class.identifier: getHostname
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String getHostname()
focal_class.class_method_signature: TCPIPClient.getPort()
focal_class.full_signature: @Override protected int getPort()
focal_class.identifier: getPort
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getPort()
focal_class.class_method_signature: TCPIPClient.getCodecClass()
focal_class.full_signature: @Override protected Class<? extends AbstractCodec> getCodecClass()
focal_class.identifier: getCodecClass
focal_class.modifiers: @Override protected
focal_class.parameters: ()
focal_class.return: Class<? extends AbstractCodec>
focal_class.signature: Class<? extends AbstractCodec> getCodecClass()
focal_class.class_method_signature: TCPIPClient.createMessageHelper(IMessageFactory messageFactory, IDictionaryStructure dictionary)
focal_class.full_signature: @Override protected MessageHelper createMessageHelper(IMessageFactory messageFactory, IDictionaryStructure dictionary)
focal_class.identifier: createMessageHelper
focal_class.modifiers: @Override protected
focal_class.parameters: (IMessageFactory messageFactory, IDictionaryStructure dictionary)
focal_class.return: MessageHelper
focal_class.signature: MessageHelper createMessageHelper(IMessageFactory messageFactory, IDictionaryStructure dictionary)
focal_class.superclass: extends AbstractMINATCPService
focal_method.body: @Override
  	public TCPIPSession getSession() {
          return (TCPIPSession)super.getSession();
  	}
focal_method.class_method_signature: TCPIPClient.getSession()
focal_method.full_signature: @Override public TCPIPSession getSession()
focal_method.identifier: getSession
focal_method.invocations: getSession
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: TCPIPSession
focal_method.signature: TCPIPSession getSession()