OK, so I was looking at the logs on the java side, it appears to be a
problem there, when I first add the route, the following shows up in
the log:
2011-09-20 11:14:16,959 INFO [MINANetworkDriver(Acceptor)-4] (Log4jMessageLogge
r.java:72) - [con:1(null@/xxx.xxx.xxx.xxx:58351/localhost)] CON-1001 :
Open : Clie
nt ID : null : Protocol Version : 0-10
2011-09-20 11:14:41,820 ERROR [MINANetworkDriver(Acceptor)-5] (MINANetworkDriver
.java:315) - Exception thrown and no ProtocolEngine to handle it
org.apache.qpid.transport.ProtocolViolationException: Received frames for an alr
eady dettached session
at org.apache.qpid.transport.Connection.dispatch(Connection.java:408)
at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegat
e.java:64)
at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegat
e.java:40)
at org.apache.qpid.transport.MethodDelegate.sessionAttached(MethodDelega
te.java:68)
at org.apache.qpid.transport.SessionAttached.dispatch(SessionAttached.ja
va:96)
at org.apache.qpid.transport.ConnectionDelegate.control(ConnectionDelega
te.java:49)
at org.apache.qpid.transport.ConnectionDelegate.control(ConnectionDelega
te.java:40)
at org.apache.qpid.transport.Method.delegate(Method.java:163)
at org.apache.qpid.transport.Connection.received(Connection.java:369)
at org.apache.qpid.server.transport.ServerConnection.received(ServerConn
ection.java:204)
at org.apache.qpid.server.transport.ServerConnection.received(ServerConn
ection.java:52)
......snip......
I also tried to do a pull route from the java side and got a different
exception:
2011-09-20 11:17:16,682 INFO [MINANetworkDriver(Acceptor)-8] (Log4jMessageLogge
r.java:72) - [con:2(null@/xxx.xxx.xxx.xxx:22891/localhost)/ch:1]
[vh(/localhost)/e
x(management/qpid.management)/qu(topic-NOVELL-4OFTOTK4.16124.1)/rk(console.event
.*.*.org.apache.qpid.broker.agent)] BND-1001 : Create
2011-09-20 11:17:16,766 ERROR [MINANetworkDriver(Acceptor)-2] (MINANetworkDriver
.java:315) - Exception thrown and no ProtocolEngine to handle it
java.lang.NullPointerException
at org.apache.qpid.qmf.schema.BrokerSchema$BrokerClass$ConnectMethodInvo
cation.execute(BrokerSchema.java:825)
at org.apache.qpid.qmf.schema.BrokerSchema$BrokerClass$ConnectMethodInvo
cation.execute(BrokerSchema.java:786)
at org.apache.qpid.qmf.QMFMethodRequestCommand.process(QMFMethodRequestC
ommand.java:61)
at org.apache.qpid.qmf.ManagementExchange$ManagementQueue.enqueue(Manage
mentExchange.java:109)
at org.apache.qpid.server.transport.ServerSession$1.postCommit(ServerSes
sion.java:181)
at org.apache.qpid.server.txn.AutoCommitTransaction.enqueue(AutoCommitTr
ansaction.java:212)
at org.apache.qpid.server.transport.ServerSession.enqueue(ServerSession.
java:170)
at org.apache.qpid.server.transport.ServerSessionDelegate.messageTransfe
r(ServerSessionDelegate.java:332)
at org.apache.qpid.server.transport.ServerSessionDelegate.messageTransfe
r(ServerSessionDelegate.java:96)
at org.apache.qpid.transport.MessageTransfer.dispatch(MessageTransfer.ja
va:108)
at org.apache.qpid.transport.SessionDelegate.command(SessionDelegate.jav
a:50)
at org.apache.qpid.server.transport.ServerSessionDelegate.command(Server
SessionDelegate.java:112)
at org.apache.qpid.server.transport.ServerSessionDelegate.command(Server
SessionDelegate.java:96)
at org.apache.qpid.transport.Method.delegate(Method.java:159)
at org.apache.qpid.transport.Session.received(Session.java:528)
at org.apache.qpid.transport.Connection.dispatch(Connection.java:404)
at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegat
e.java:64)
at org.apache.qpid.transport.ConnectionDelegate.handle(ConnectionDelegat
....snip....
Any ideas? should I submit a bug?
On Tue, Sep 20, 2011 at 5:51 AM, Gordon Sim <[email protected]> wrote:
> On 09/20/2011 07:57 AM, Brandon Pedersen wrote:
>>
>> Hi, I am starting to play around with federation/routes. So I have a
>> local c++ broker with a topic exchange. I want to route all messages
>> to the same exchange on a remote java broker (a push route). So I do
>> the following locally:
>>
>> qpid-config add exchange topic myexchange
>> qpid-route -s route add admin/admin@remote-java-broker local-broker
>> myexchange '#'
>>
>> I then use the spout script to send a message to the local exchange,
>> however, the message never shows up on the remote end (qpid-stat shows
>> 0 messages received on the remote exchange). I can see that the link
>> is up using qpid-route and the logs show that a bridge queue is
>> created. Is there something I am missing? Or does this just not work
>> going between c++ and java?
>
> I have never tried that myself. What does qpid-stat show for the local
> broker (i.e. c++ broker)? Are there any messages in the queue? Is there a
> subscription for the queue and has it delivered any messages?
>
> You could also try a pull route (i.e. have the java broker pull messages) to
> see if it is the push route that is the issue.
>
> ---------------------------------------------------------------------
> Apache Qpid - AMQP Messaging Implementation
> Project: http://qpid.apache.org
> Use/Interact: mailto:[email protected]
>
>
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
