Thanks for the bug report. Could you also open an issue at:
https://issues.apache.org/jira/browse/APLO
On Tue, Feb 7, 2012 at 4:20 AM, Michael Justin <michael.jus...@gmx.net>wrote:
> Hello,
>
> When the Stomp client opens a queue browser, the broker logs an
> AssertionError:
>
> send:
> CONNECT
> login:admin
> passcode:password
> accept-version:1.0,1.1
> server:localhost
> heart-beat:0,0
>
>
>
> received:
> CONNECTED
> version:1.1
> server:apache-apollo/1.0
> session:mybroker-1238
> heart-beat:100,10000
> user-id:admin
>
>
> send:
> SUBSCRIBE
> destination:/queue/TOOL.**DEFAULT
> id:{28C1F8E4-3125-4FDD-B2A6-**CC14DCDE9EE3}
>
>
>
> send:
> SEND
> destination:/queue/TOOL.**DEFAULT
>
>
>
> send:
> SEND
> destination:/queue/TOOL.**DEFAULT
>
>
>
> send:
> SUBSCRIBE
> destination:/queue/TOOL.**DEFAULT
> id:{5A963ED4-9799-4FD0-B6DC-**96E3C9446401}
> browser:true
>
>
> -> when this subscribe frame has been sent, the broker logs:
>
> WARN | java.lang.AssertionError: assertion failed:
> this.rejection_handler.$eq$eq(**null)
>
>
> A minor problem is in the browser:end message frame, the subscription id
> is repeated:
>
> received:
> MESSAGE
> subscription:{5A963ED4-9799-**4FD0-B6DC-96E3C9446401}
> subscription:{5A963ED4-9799-**4FD0-B6DC-96E3C9446401}
> destination:
> message-id:
> browser:end
>
>
> And there is an exception when the client disconnects after it has read
> the queue browser until the end:
>
> java.lang.AssertionError: stomp subscription id: {5A963ED4-9799-4FD0-B6DC-
> **96E3C9
> 446401}, remote address: /127.0.0.1:50646: Use of object not allowed
> after it ha
> s been released.
> at org.fusesource.hawtdispatch.**BaseRetained.assertRetained(**
> BaseRetained.
> java:157)
> at org.fusesource.hawtdispatch.**BaseRetained.retain(**
> BaseRetained.java:79)
>
> at org.apache.activemq.apollo.**broker.LocalRouter.unbind(**
> LocalRouter.scal
> a:1058)
> at org.apache.activemq.apollo.**stomp.StompProtocolHandler$$**
> anonfun$on_tra
> nsport_disconnected$2.apply(**StompProtocolHandler.scala:**722)
> at org.apache.activemq.apollo.**stomp.StompProtocolHandler$$**
> anonfun$on_tra
> nsport_disconnected$2.apply(**StompProtocolHandler.scala:**720)
> at scala.collection.immutable.**Map$Map2.foreach(Map.scala:**139)
> at org.apache.activemq.apollo.**stomp.StompProtocolHandler.on_**
> transport_di
> sconnected(**StompProtocolHandler.scala:**720)
> at org.apache.activemq.apollo.**stomp.StompProtocolHandler.on_**
> transport_co
> mmand(StompProtocolHandler.**scala:787)
> at org.apache.activemq.apollo.**broker.BrokerConnection.on_**
> transport_comma
> nd(Connection.scala:125)
> at org.apache.activemq.apollo.**broker.Connection$$anon$1.**
> onTransportComma
> nd(Connection.scala:51)
> at org.fusesource.hawtdispatch.**transport.TcpTransport.**
> drainInbound(TcpTr
> ansport.java:597)
> at org.fusesource.hawtdispatch.**transport.TcpTransport$6.run(**
> TcpTransport
> .java:472)
> at org.fusesource.hawtdispatch.**internal.NioDispatchSource$3.**
> run(NioDispa
> tchSource.java:226)
> at org.fusesource.hawtdispatch.**internal.SerialDispatchQueue.**
> run(SerialDi
> spatchQueue.java:83)
> at org.fusesource.hawtdispatch.**internal.pool.SimpleThread.**
> run(SimpleThre
> ad.java:61)
>
> I can reproduce it on every broker run, using Apollo 1.0 final
>
> Regards
> --
> Michael Justin
> habarisoft - Enterprise Messaging Software for Delphi
> http://www.habarisoft.com/
>
--
**
*Hiram Chirino*
*Software Fellow | FuseSource Corp.*
*chir...@fusesource.com | fusesource.com*
*skype: hiramchirino | twitter: @hiramchirino<http://twitter.com/hiramchirino>
*
*blog: Hiram Chirino's Bit Mojo <http://hiramchirino.com/blog/>*
*
*
*
*
