activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gabriel kastenbaum <gkastenbaummailingl...@gmail.com>
Subject transportConnector using multicast (was: Several transportConnectors and clustering)
Date Wed, 27 Sep 2006 09:06:49 GMT
Hi,

I am (still) trying to use multicast in a transportConnector with 
ActiveMQ 4.0.1 (and 4.0.2-snapshot)

Can I use multicast in a transportConnector?

I can use multicast for discovery but for now i can not make it work for 
a transportConnector.

The simplest test i managed to do is: goto to the example.
Change the URL in the build.xml to :
<property name="url" value="multicast://225.0.0.1:61620" />
   

Start the producer:
*ant producer
*
But .... it does not seem to work :-\


     [echo] Running producer against server at $url = 
multicast://225.0.0.1:61620 for subject $subject = Syntheses
     [java] Connecting to URL: multicast://225.0.0.1:61620
     [java] Publishing a Message with size 1000 to queue: Syntheses
     [java] Using non-durable publishing
     [java] Sleeping between publish 0 ms
     [java] DEBUG MulticastTransport             - Joining multicast 
address: /225.0.0.1
     [java] DEBUG UdpTransport                   - Consumer thread 
starting for: multicast://225.0.0.1:61620@0
     [java] DEBUG UdpTransport                   - Sending oneway from: 
multicast://225.0.0.1:61620@0 to target: /225.0.
0.1:61620 command: ConnectionInfo {commandId = 1, responseRequired = 
true, connectionId = ID:ZOZMA-2042-1159347487015-0:
0, clientId = ID:ZOZMA-2042-1159347487015-1:0, userName = null, password 
= null, brokerPath = null, brokerMasterConnecto
r = false, manageable = true}
     [java] DEBUG DefaultReplayBuffer            - Adding command ID: 1 
to replay buffer: org.apache.activemq.transport.
reliable.DefaultReplayBuffer@1b3f829 object: [B@698403
     [java] DEBUG CommandDatagramSocket          - Channel: 
multicast://225.0.0.1:61620@0 sending datagram: 1 to: /225.0
.0.1:61620
     [java] DEBUG CommandDatagramSocket          - Channel: 
multicast://225.0.0.1:61620@0 about to process: ConnectionIn
fo {commandId = 1, responseRequired = true, connectionId = 
ID:ZOZMA-2042-1159347487015-0:0, clientId = ID:ZOZMA-2042-115
9347487015-1:0, userName = null, password = null, brokerPath = null, 
brokerMasterConnector = false, manageable = true}
     [java] DEBUG ReliableTransport              - Still waiting for 
response on: multicast://225.0.0.1:61620@0 to comma
nd: ConnectionInfo {commandId = 1, responseRequired = true, connectionId 
= ID:ZOZMA-2042-1159347487015-0:0, clientId = I
D:ZOZMA-2042-1159347487015-1:0, userName = null, password = null, 
brokerPath = null, brokerMasterConnector = false, mana
geable = true} sending replay message
     [java] DEBUG UdpTransport                   - Sending oneway from: 
multicast://225.0.0.1:61620@0 to target: /192.9.
211.39:61620 command: ReplayCommand {commandId = 2, firstNakNumber = 1, 
lastNakNumber = 1}
     [java] DEBUG DefaultReplayBuffer            - Adding command ID: 2 
to replay buffer: org.apache.activemq.transport.
reliable.DefaultReplayBuffer@1b3f829 object: [B@d02b51
     [java] DEBUG CommandDatagramSocket          - Channel: 
multicast://225.0.0.1:61620@0 sending datagram: 2 to: /192.9
.211.39:61620
     [java] DEBUG CommandDatagramSocket          - Channel: 
multicast://225.0.0.1:61620@0 about to process: ReplayComman
d {commandId = 2, firstNakNumber = 1, lastNakNumber = 1}
     [java] DEBUG ReliableTransport              - Processing replay 
command: ReplayCommand {commandId = 2, firstNakNumb
er = 1, lastNakNumber = 1}
     [java] DEBUG DefaultReplayBuffer            - Buffer: 
org.apache.activemq.transport.reliable.DefaultReplayBuffer@1b
3f829 replaying messages from: 1 to: 1
*     [java] DEBUG CommandDatagramSocket          - Channel: 
multicast://225.0.0.1:61620@0 REDELIVERING datagram: 1 to: /
225.0.0.1:61620*

Mime
View raw message