You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by j0llyr0g3r <ti...@wincor-nixdorf.com> on 2007/10/01 15:44:56 UTC
Brokers + SSL = Message loss?
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 =
org.apache.activemq.util.ByteSequence@2a6f16, 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 =
org.apache.activemq.util.ByteSequence@1e3118a, 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 =
org.apache.activemq.util.ByteSequence@94884d, 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>
--
View this message in context: http://www.nabble.com/Brokers-%2B-SSL-%3D-Message-loss--tf4548451s2354.html#a12979485
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Brokers + SSL = Message loss?
Posted by Rob Davies <ra...@gmail.com>.
:)
On Oct 1, 2007, at 3:13 PM, j0llyr0g3r wrote:
>
> Ok, please forget this embarassing posting......
>
> Ah colleague of mine had another consumer running on the same
> queue, and i
> had totally forgotten about this...
>
>
>
> j0llyr0g3r wrote:
>>
>> 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 =
>> org.apache.activemq.util.ByteSequence@2a6f16, 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 =
>> org.apache.activemq.util.ByteSequence@1e3118a, 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 =
>> org.apache.activemq.util.ByteSequence@94884d, 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>
>>
>
> --
> View this message in context: http://www.nabble.com/Brokers-%2B-SSL-
> %3D-Message-loss--tf4548451s2354.html#a12979880
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
Re: Brokers + SSL = Message loss?
Posted by j0llyr0g3r <ti...@wincor-nixdorf.com>.
Ok, please forget this embarassing posting......
Ah colleague of mine had another consumer running on the same queue, and i
had totally forgotten about this...
j0llyr0g3r wrote:
>
> 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 =
> org.apache.activemq.util.ByteSequence@2a6f16, 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 =
> org.apache.activemq.util.ByteSequence@1e3118a, 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 =
> org.apache.activemq.util.ByteSequence@94884d, 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>
>
--
View this message in context: http://www.nabble.com/Brokers-%2B-SSL-%3D-Message-loss--tf4548451s2354.html#a12979880
Sent from the ActiveMQ - User mailing list archive at Nabble.com.