activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j0llyr0g3r <timo.roess...@wincor-nixdorf.com>
Subject Re: Brokers + SSL = Message loss?
Date Mon, 01 Oct 2007 14:13:48 GMT

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