[
https://issues.apache.org/jira/browse/ARTEMIS-460?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15215708#comment-15215708
]
Ari Tilli commented on ARTEMIS-460:
-----------------------------------
.Forget to say that by testing with jms.queue.XXXX everything works, so this is
like for some reason private queue registered for topic is not "registered"
properly
Some logs, will try to check sources later.
1) Connection created...
18:46:35,058 FINE [io.netty.util.Recycler]
-Dio.netty.recycler.maxCapacity.default: 262144
18:46:35,183 FINE [org.apache.qpid.proton.engine.impl.SaslImpl] SASL
negotiation done: SaslImpl [_outcome=PN_SASL_OK, state=PN_SASL_PASS, done=true,
role=SERVER]
18:46:35,187 FINE [proton.trace] IN: CH[0] : Open{
containerId='69d4371f-b0d4-416c-b8d2-97e703ac7f3d', hostname='null',
maxFrameSize=4294967295, channelMax=32767, idleTimeOut=null,
outgoingLocales=null, incomingLocales=null, offeredCapabilities=null,
desiredCapabilities=null, properties={qpid.client_process=qpidtester,
qpid.client_pid=5499, qpid.client_ppid=2534}}
2) Session created ??
18:46:35,191 FINE [proton.trace] IN: CH[0] : Begin{remoteChannel=null,
nextOutgoingId=0, incomingWindow=2147483647, outgoingWindow=2147483647,
handleMax=4294967295, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
3) Receiver created...
18:46:35,213 FINE [proton.trace] IN: CH[0] :
Attach{name='jms.topic.TMS.TimetableHandlerClient_cdca5f38-7d32-47eb-967f-16bbe757eddb',
handle=0, role=RECEIVER, sndSettleMode=MIXED, rcvSettleMode=FIRST,
source=Source{address='jms.topic.TMS.TimetableHandlerClient', durable=NONE,
expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null,
distributionMode=null, filter=null, defaultOutcome=null, outcomes=null,
capabilities=null},
target=Target{address='jms.topic.TMS.TimetableHandlerClient', durable=NONE,
expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null,
capabilities=null}, unsettled=null, incompleteUnsettled=false,
initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
4) Seems to add consumer....
18:46:35,221 DEBUG [org.apache.activemq.artemis.core.server]
QueueImpl[name=jms.topic.TMS.TimetableHandlerClient, postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de
adding consumer ServerConsumerImpl [id=0, filter=null,
binding=LocalQueueBinding [address=jms.topic.TMS.TimetableHandlerClient,
queue=QueueImpl[name=jms.topic.TMS.TimetableHandlerClient,
postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de,
filter=FilterImpl [sfilterString=__AMQX=-1],
name=jms.topic.TMS.TimetableHandlerClient,
clusterName=jms.topic.TMS.TimetableHandlerClient28c301c8-de4b-11e5-9091-ac162d75c5d4]]
18:46:35,222 DEBUG [org.apache.activemq.artemis.core.server] Session with
user=null,
connection=org.apache.activemq.artemis.core.protocol.proton.ActiveMQProtonRemotingConnection@69c3ea63
created a consumer on queue jms.topic.TMS.TimetableHandlerClient, filter = null
18:46:35,226 DEBUG [org.apache.activemq.artemis.core.server] Couldn't find any
bindings for address=activemq.notifications on
message=ServerMessage[messageID=13184376,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true,
address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=jms.topic.TMS.TimetableHandlerClient,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=6ab000e9-f5c5-11e5-9e76-ac162d75c5d6,_AMQ_Address=jms.topic.TMS.TimetableHandlerClient,_AMQ_RemoteAddress=/127.0.0.1:52168,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1459266395224,_AMQ_ClusterName=jms.topic.TMS.TimetableHandlerClient28c301c8-de4b-11e5-9091-ac162d75c5d4]]@547651281
18:46:35,226 DEBUG [org.apache.activemq.artemis.core.server] Message
ServerMessage[messageID=13184376,durable=true,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=true,
address=activemq.notifications,properties=TypedProperties[_AMQ_RoutingName=jms.topic.TMS.TimetableHandlerClient,_AMQ_Distance=0,_AMQ_ConsumerCount=1,_AMQ_User=NULL-value,_AMQ_SessionName=6ab000e9-f5c5-11e5-9e76-ac162d75c5d6,_AMQ_Address=jms.topic.TMS.TimetableHandlerClient,_AMQ_RemoteAddress=/127.0.0.1:52168,_AMQ_NotifType=CONSUMER_CREATED,_AMQ_NotifTimestamp=1459266395224,_AMQ_ClusterName=jms.topic.TMS.TimetableHandlerClient28c301c8-de4b-11e5-9091-ac162d75c5d4]]@547651281
is not going anywhere as it didn't have a binding on
address:activemq.notifications
18:46:35,226 DEBUG [org.apache.activemq.artemis.core.server] ServerConsumerImpl
[id=0, filter=null, binding=LocalQueueBinding
[address=jms.topic.TMS.TimetableHandlerClient,
queue=QueueImpl[name=jms.topic.TMS.TimetableHandlerClient,
postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de,
filter=FilterImpl [sfilterString=__AMQX=-1],
name=jms.topic.TMS.TimetableHandlerClient,
clusterName=jms.topic.TMS.TimetableHandlerClient28c301c8-de4b-11e5-9091-ac162d75c5d4]]::
FlowControl::Received disable flow control message
18:46:35,226 DEBUG [org.apache.activemq.artemis.core.server]
QueueImpl[name=jms.topic.TMS.TimetableHandlerClient, postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de
doing deliver. messageReferences=0
18:46:35,226 DEBUG [org.apache.activemq.artemis.core.server]
QueueImpl[name=jms.topic.TMS.TimetableHandlerClient, postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de
doing deliver. messageReferences=0
5) Message comes...
18:46:35,229 FINE [proton.trace] IN: CH[1] : Begin{remoteChannel=null,
nextOutgoingId=0, incomingWindow=2147483647, outgoingWindow=2147483647,
handleMax=4294967295, offeredCapabilities=null, desiredCapabilities=null,
properties=null}
18:46:35,230 FINE [proton.trace] IN: CH[1] :
Attach{name='jms.topic.TMS.TimetableHandlerClient_b2df13c5-2c4e-4eee-bf55-5e610703141e',
handle=0, role=SENDER, sndSettleMode=MIXED, rcvSettleMode=FIRST,
source=Source{address='jms.topic.TMS.TimetableHandlerClient', durable=NONE,
expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null,
distributionMode=null, filter=null, defaultOutcome=null, outcomes=null,
capabilities=null},
target=Target{address='jms.topic.TMS.TimetableHandlerClient', durable=NONE,
expiryPolicy=SESSION_END, timeout=0, dynamic=false, dynamicNodeProperties=null,
capabilities=null}, unsettled=null, incompleteUnsettled=false,
initialDeliveryCount=0, maxMessageSize=null, offeredCapabilities=null,
desiredCapabilities=null, properties=null}
18:46:35,233 FINE [proton.trace] IN: CH[1] : Transfer{handle=0, deliveryId=0,
deliveryTag=\x00\x00\x00\x00, messageFormat=0, settled=false, more=false,
rcvSettleMode=null, state=null, resume=false, aborted=false,
batchable=false}[\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Su\xa04Test
message to jms.topic.TMS.TimetableHandlerClient]
6) .. but is not going anywhere
18:46:35,249 DEBUG [org.apache.activemq.artemis.core.server] Message
ServerMessage[messageID=13184379,durable=false,userID=null,priority=0,
bodySize=512, timestamp=0,expiration=0, durable=false,
address=jms.topic.TMS.TimetableHandlerClient,properties=TypedProperties[JMS_AMQP_NATIVE=false,JMS_AMQP_MESSAGE_FORMAT=0]]@72251282
is not going anywhere as it didn't have a binding on
address:jms.topic.TMS.TimetableHandlerClient
18:46:40,233 FINE [proton.trace] IN: CH[0] : Flow{nextIncomingId=1,
incomingWindow=2147483647, nextOutgoingId=0, outgoingWindow=2147483647,
handle=0, deliveryCount=0, linkCredit=1, available=null, drain=false,
echo=false, properties=null}
18:46:40,233 DEBUG [org.apache.activemq.artemis.core.server] ServerConsumerImpl
[id=0, filter=null, binding=LocalQueueBinding
[address=jms.topic.TMS.TimetableHandlerClient,
queue=QueueImpl[name=jms.topic.TMS.TimetableHandlerClient,
postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de,
filter=FilterImpl [sfilterString=__AMQX=-1],
name=jms.topic.TMS.TimetableHandlerClient,
clusterName=jms.topic.TMS.TimetableHandlerClient28c301c8-de4b-11e5-9091-ac162d75c5d4]]::
FlowControl::Received disable flow control message
18:46:40,234 DEBUG [org.apache.activemq.artemis.core.server]
QueueImpl[name=jms.topic.TMS.TimetableHandlerClient, postOffice=PostOfficeImpl
[server=ActiveMQServerImpl::serverUUID=28c301c8-de4b-11e5-9091-ac162d75c5d4]]@36bc55de
doing deliver. messageReferences=0
18:46:56,133 DEBUG [org.apache.activemq.artemis.core.server] Cannot expire from
jms.queue.ExpiryQueue into jms.queue.ExpiryQueue
> AMQP topic subcription not working (qpid-cpp)
> ---------------------------------------------
>
> Key: ARTEMIS-460
> URL: https://issues.apache.org/jira/browse/ARTEMIS-460
> Project: ActiveMQ Artemis
> Issue Type: Bug
> Components: AMQP
> Affects Versions: 1.3.0
> Environment: RHEL 7.2 + openJDK
> Reporter: Ari Tilli
>
> This might be stupid user error (some flags missing) but on git-version
> I can not get topics working through AMQP wiht qpid-cpp
> 1) Topics are defined in broker.xml
> 2) Create a receiver in session and when sending message to itself, message
> is not received. (Does not work even from different app, so not related to
> using same session)
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
