Hallo!
I am trying to run the TRCC Contribution example.
It goes until calling of consumer.registerClient, then i see message "Attempt to get servieId while it is not set" and no progress anymore. Debug all doesn't show any helpful information except of handshaking logs.
Channel config:
<Channel> <Name value="Channel_1"/> <ChannelType value="ChannelType::RSSL_ENCRYPTED"/> <Host value="chp02-emea1.thomsonreuters.com"/> <Port value="443"/> </Channel>Code:
OmmConsumerClient appClient = new OmmConsumerClientImpl(); OmmConsumer consumer = EmaFactory.createOmmConsumer(EmaFactory.createOmmConsumerConfig().tunnelingKeyStoreFile(PATH).tunnelingKeyStorePasswd(PASSWORD)); ClassOfService cos = EmaFactory.createClassOfService() .authentication(EmaFactory.createCosAuthentication() .type(CosAuthentication.CosAuthenticationType.NOT_REQUIRED)) .dataIntegrity(EmaFactory.createCosDataIntegrity() .type(CosDataIntegrity.CosDataIntegrityType.RELIABLE)) .flowControl(EmaFactory.createCosFlowControl() .type(CosFlowControl.CosFlowControlType.BIDIRECTIONAL) .recvWindowSize(1200)) .guarantee(EmaFactory.createCosGuarantee() .type(CosGuarantee.CosGuaranteeType.NONE)); System.out.println("Starting tunnel stream..."); TunnelStreamRequest tsr = EmaFactory.createTunnelStreamRequest() .classOfService(cos) .domainType(EmaRdm.MMT_SYSTEM) .name("TUNNEL1") .serviceName("TEST_SERVICE"); long tunnelStreamHandle = consumer.registerClient(tsr, appClient);Output without -Djavax.net.debug=all:
Contributing to TR Contributions Channel Starting encrypted connection... Jun 06, 2019 8:09:01 AM com.thomsonreuters.ema.access.ChannelCallbackClient reactorChannelEventCallback INFORMATION: loggerMsg ClientName: ChannelCallbackClient Severity: Info Text: Received ChannelUp event on channel Channel_1 Instance Name Consumer_1_1 Component Version eta3.1.1.L1.linux.rrg 64-bit Static loggerMsgEnd <!-- Outgoing Reactor message --> <!-- java.nio.channels.SocketChannel[connected local=/192.168.178.24:52225 remote=chp02-emea1.thomsonreuters.com/159.220.25.3:443] --> <!-- Thu Jun 06 08:09:02 CEST 2019 --> <!-- rwfMajorVer="14" rwfMinorVer="1" --> <REQUEST domainType="LOGIN" streamId="1" containerType="NO_DATA" flags="0x04 (STREAMING)" dataSize="0"> <key flags="0x26 (HAS_NAME|HAS_NAME_TYPE|HAS_ATTRIB)" name="Stephan" nameType="1" attribContainerType="ELEMENT_LIST"> <attrib> <elementList flags="0x08 (HAS_STANDARD_DATA)"> <elementEntry name="ApplicationId" dataType="ASCII_STRING" data="256"/> <elementEntry name="ApplicationName" dataType="ASCII_STRING" data="ema"/> <elementEntry name="Position" dataType="ASCII_STRING" data="192.168.178.24/DESKTOP-UKCVPSB"/> <elementEntry name="Role" dataType="UINT" data="0"/> </elementList> </attrib> </key> <dataBody> </dataBody> </REQUEST> <!-- Incoming Reactor message --> <!-- java.nio.channels.SocketChannel[connected local=/192.168.178.24:52225 remote=chp02-emea1.thomsonreuters.com/159.220.25.3:443] --> <!-- Thu Jun 06 08:09:02 CEST 2019 --> <!-- rwfMajorVer="14" rwfMinorVer="1" --> <REFRESH domainType="LOGIN" streamId="1" containerType="NO_DATA" flags="0x168 (HAS_MSG_KEY|SOLICITED|REFRESH_COMPLETE|CLEAR_CACHE)" groupId="0" State: Open/Ok/None - text: "" dataSize="0"> <key flags="0x26 (HAS_NAME|HAS_NAME_TYPE|HAS_ATTRIB)" name="Stephan" nameType="1" attribContainerType="ELEMENT_LIST"> <attrib> <elementList flags="0x08 (HAS_STANDARD_DATA)"> <elementEntry name="ApplicationId" dataType="ASCII_STRING" data="256"/> <elementEntry name="ApplicationName" dataType="ASCII_STRING" data="ema"/> <elementEntry name="Position" dataType="ASCII_STRING" data="192.168.178.24/DESKTOP-UKCVPSB"/> <elementEntry name="SingleOpen" dataType="UINT" data="0"/> <elementEntry name="SupportOMMPost" dataType="UINT" data="1"/> <elementEntry name="SupportBatchRequests" dataType="UINT" data="5"/> </elementList> </attrib> </key> <dataBody> </dataBody> </REFRESH> <!-- Outgoing Reactor message --> <!-- java.nio.channels.SocketChannel[connected local=/192.168.178.24:52225 remote=chp02-emea1.thomsonreuters.com/159.220.25.3:443] --> <!-- Thu Jun 06 08:09:02 CEST 2019 --> <!-- rwfMajorVer="14" rwfMinorVer="1" --> <REQUEST domainType="SOURCE" streamId="2" containerType="NO_DATA" flags="0x04 (STREAMING)" dataSize="0"> <key flags="0x08 (HAS_FILTER)" filter="63"/> <dataBody> </dataBody> </REQUEST> <!-- Incoming Reactor message --> <!-- java.nio.channels.SocketChannel[connected local=/192.168.178.24:52225 remote=chp02-emea1.thomsonreuters.com/159.220.25.3:443] --> <!-- Thu Jun 06 08:09:02 CEST 2019 --> <!-- rwfMajorVer="14" rwfMinorVer="1" --> <REFRESH domainType="SOURCE" streamId="2" containerType="MAP" flags="0x168 (HAS_MSG_KEY|SOLICITED|REFRESH_COMPLETE|CLEAR_CACHE)" groupId="0" State: Open/Ok/None - text: "" dataSize="249"> <key flags="0x08 (HAS_FILTER)" filter="63"/> <dataBody> <map flags="0x00" countHint="0" keyPrimitiveType="UINT" containerType="FILTER_LIST" > <mapEntry flags="0x00" action="ADD" key="10" > <filterList containerType="ELEMENT_LIST" countHint="0" flags="0x00"> <filterEntry id="1" action="SET" flags="0x00" containerType="ELEMENT_LIST"> <elementList flags="0x08 (HAS_STANDARD_DATA)"> <elementEntry name="Name" dataType="ASCII_STRING" data="DDS_TRCE"/> <elementEntry name="Vendor" dataType="ASCII_STRING" data="Thomson Reuters RTTG Core Development"/> <elementEntry name="Capabilities" dataType="ARRAY"> <array itemLength="0" primitiveType="UINT"> <arrayEntry data="6"/> <arrayEntry data="127"/> </array> </elementEntry> <elementEntry name="QoS" dataType="ARRAY"> <array itemLength="0" primitiveType="QOS"> <arrayEntry Qos: Realtime/TickByTick/Static - timeInfo: 0 - rateInfo: 0/> </array> </elementEntry> </elementList> </filterEntry> <filterEntry id="2" action="SET" flags="0x00" containerType="ELEMENT_LIST"> <elementList flags="0x08 (HAS_STANDARD_DATA)"> <elementEntry name="ServiceState" dataType="UINT" data="1"/> <elementEntry name="AcceptingRequests" dataType="UINT" data="1"/> <elementEntry name="Status" dataType="STATE" State: Open/Ok/None - text: ""/> </elementList> </filterEntry> <filterEntry id="4" action="SET" flags="0x00" containerType="ELEMENT_LIST"> <elementList flags="0x08 (HAS_STANDARD_DATA)"> <elementEntry name="OpenWindow" dataType="UINT" data="6"/> </elementList> </filterEntry> <filterEntry id="6" action="SET" flags="0x02 (HAS_CONTAINER_TYPE)" containerType="MAP"> <map flags="0x00" countHint="0" keyPrimitiveType="ASCII_STRING" containerType="ELEMENT_LIST" > <mapEntry flags="0x00" action="ADD" key="DDS_TRCE" > <elementList flags="0x08 (HAS_STANDARD_DATA)"> <elementEntry name="Type" dataType="UINT" data="1"/> <elementEntry name="LinkState" dataType="UINT" data="1"/> </elementList> </mapEntry> </map> </filterEntry> </filterList> </mapEntry> </map> </dataBody> </REFRESH> Starting tunnel stream... Registering client... Attempt to get servieId while it is not set.