activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Rob Davies <rajdav...@gmail.com>
Subject Re: Brokers + SSL = Message loss?
Date Mon, 01 Oct 2007 14:49:11 GMT
:)
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.
>


Mime
View raw message