Hey folks,
i got a strange problem here:
I connected two brokers, let's say A and B, using SSL.
Then i started the activemq-consumer example and the activemq-
producer
example.
Surprisingly, some messages are NOT received.
Here is the output of the consumer:
consumer:
[echo] Running consumer against server at $url =
tcp://wnmf-proto-gw-2:61616 for subject $subject = ice
[java] Connecting to URL: tcp://wnmf-proto-gw-2:61616
[java] Consuming queue: ice
[java] Using a non-durable subscription
[java] We are about to wait until we consume: 10 message(s)
then we
will shutdown
[java] Received: Message: 1 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: Message: 3 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: Message: 4 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: Message: 5 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: Message: 7 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: Message: 8 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: Message: 9 sent at: Mon Oct 01 15:23:24 CEST
2007
...
[java] Received: ActiveMQBytesMessage {commandId = 6,
responseRequired = true, messageId =
2270fed1-5e7f-4624-94b8-ccad7180cc37:1:1:2, originalDestination =
null,
originalTransactionId = null, producerId =
2270fed1-5e7f-4624-94b8-ccad7180cc37:1:1, destination = queue://ice,
transactionId = null, expiration = 0, timestamp = 1191245366791,
arrival =
0, correlationId = null, replyTo = null, persistent = true, type =
null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId
= null,
compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties
= null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null,
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn =
null }
[java] Received: ActiveMQBytesMessage {commandId = 8,
responseRequired = true, messageId =
2270fed1-5e7f-4624-94b8-ccad7180cc37:1:1:4, originalDestination =
null,
originalTransactionId = null, producerId =
2270fed1-5e7f-4624-94b8-ccad7180cc37:1:1, destination = queue://ice,
transactionId = null, expiration = 0, timestamp = 1191245366847,
arrival =
0, correlationId = null, replyTo = null, persistent = true, type =
null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId
= null,
compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties =
null, dataStructure = null, redeliveryCounter = 0, size = 0,
properties =
null, readOnlyProperties = true, readOnlyBody = true, droppable =
false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn =
null }
[java] Received: ActiveMQBytesMessage {commandId = 10,
responseRequired = true, messageId =
2270fed1-5e7f-4624-94b8-ccad7180cc37:1:1:6, originalDestination =
null,
originalTransactionId = null, producerId =
2270fed1-5e7f-4624-94b8-ccad7180cc37:1:1, destination = queue://ice,
transactionId = null, expiration = 0, timestamp = 1191245366886,
arrival =
0, correlationId = null, replyTo = null, persistent = true, type =
null,
priority = 4, groupID = null, groupSequence = 0, targetConsumerId
= null,
compressed = false, userID = null, content =
[EMAIL PROTECTED], marshalledProperties
= null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties
= null,
readOnlyProperties = true, readOnlyBody = true, droppable = false}
ActiveMQBytesMessage{ bytesOut = null, dataOut = null, dataIn =
null }
[java] Closing connection
BUILD SUCCESSFUL
Total time: 2 minutes 13 seconds
As you can see, Message 2 + 6 are not received?
Without SSL, i don't see this phenomenon.
Any ideas on this?
I configured SSL like described in the documentation here:
http://activemq.apache.org/how-do-i-use-ssl.html
Here is my configuration:
Broker A:
<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:
61616"/>
<transportConnector name="local_ssl" uri="ssl://localhost:
61617"/>
</transportConnectors>
<networkConnectors>
<networkConnector name="remote_ssl"
uri="static://(ssl://wnmf-proto-gw-1:61617)" failover="false"/>
</networkConnectors>
Broker B:
<transportConnectors>
<transportConnector name="openwire" uri="tcp://localhost:
61616"/>
<transportConnector name="local_ssl" uri="ssl://localhost:
61617"/>
</transportConnectors>
<networkConnectors>
<networkConnector name="remote_ssl"
uri="static://(ssl://wnmf-proto-gw-2:61617)" failover="false"/>
</networkConnectors>
