You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by "kim.pepper" <ki...@pepper.id.au> on 2006/03/23 23:36:49 UTC

can receive locally sent messages but can't receive remote messages

Hi,

I've been trying to use activemq 4RC1, Lingo and Jencks. I am able to
receive message when my message producer is on the same machine, but a
different webapp. But when i try to send messages from a remote machine, it
does not process them.

When I send from the local machine I get:

2006-03-24 09:17:47,748 DEBUG [transport.TransportLogger:2   ] RECEIVED:
from: null : MessageDispatch {commandId = 12, responseRequired = false,
consumerId = ID:tandoor-33094-1143152253379-1:2:-1:2, destination =
queue://com.mooter.admanager.echo, message = ActiveMQObjectMessage
{commandId = 9, responseRequired = false, messageId =
ID:tandoor-33087-1143152112014-1:2:1:1:2, originalDestination = null,
originalTransactionId = null, producerId =
ID:tandoor-33087-1143152112014-1:2:1:1, destination =
queue://com.mooter.admanager.echo, transactionId = null, expiration =
1143152297548, timestamp = 1143152267560, arrival = 0, correlationId = null,
replyTo = temp-queue://ID:tandoor-33087-1143152112014-1:2:1, persistent =
false, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.activeio.ByteSequence@53abbb, marshalledProperties = null, dataStructure
= null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false}, redeliveryCounter = 0}
2006-03-24 09:17:47,748 DEBUG [ra.ServerSessionPoolImpl      ] ServerSession
requested.
2006-03-24 09:17:47,748 DEBUG [ra.ServerSessionPoolImpl      ] Using idle
session: ServerSessionImpl:0
2006-03-24 09:17:47,748 DEBUG [ra.ServerSessionImpl:0        ] Starting run.
2006-03-24 09:17:47,748 DEBUG [ra.ServerSessionImpl:0        ] Work
accepted:
javax.resource.spi.work.WorkEvent[source=org.apache.geronimo.connector.work.GeronimoWorkManager@c5577c]
2006-03-24 09:17:47,749 DEBUG [ra.ServerSessionImpl:0        ] Work started:
javax.resource.spi.work.WorkEvent[source=Work
:ServerSessionImpl:0]2006-03-24 09:17:47,749 DEBUG [ra.ServerSessionImpl:0       
] Running
2006-03-24 09:17:47,749 DEBUG [ra.ServerSessionImpl:0        ] run loop
start
2006-03-24 09:17:47,884 DEBUG [transport.TransportLogger:2   ] SENDING:
TransactionInfo {commandId = 5, responseRequired = false, type = 0,
connectionId = ID:tandoor-33094-1143152253379-1:2, transactionId =
TX:ID:tandoor-33094-1143152253379-1:2:1}
2006-03-24 09:17:47,886 DEBUG [ServiceExporterMessageListener] Applying
RemoteInvocation: methodName='echo', parameterTypes=[class java.lang.String]
2006-03-24 09:17:47,993 DEBUG [moteInvocationTraceInterceptor] Incoming
JmsServiceExporterMessageListener remote call:
com.mooter.admanager.priv.clicktracker.EchoBean.echo
2006-03-24 09:17:47,994 DEBUG [clicktracker.EchoBeanImpl     ] RECEIVED:
blah
2006-03-24 09:17:47,994 DEBUG [moteInvocationTraceInterceptor] Finished
processing of JmsServiceExporterMessageListener remote call:
com.mooter.admanager.priv.clicktracker.EchoBean.echo
2006-03-24 09:17:47,995 DEBUG [transport.TransportLogger:2   ] SENDING:
MessageAck {commandId = 6, responseRequired = false, ackType = 2, consumerId
= ID:tandoor-33094-1143152253379-1:2:-1:2, firstMessageId =
ID:tandoor-33087-1143152112014-1:2:1:1:2, lastMessageId =
ID:tandoor-33087-1143152112014-1:2:1:1:2, destination =
queue://com.mooter.admanager.echo, transactionId =
TX:ID:tandoor-33094-1143152253379-1:2:1, messageCount = 1}2006-03-24
09:17:47,996 DEBUG [transport.TransportLogger:2   ] SENDING: TransactionInfo
{commandId = 7, responseRequired = true, type = 2, connectionId =
ID:tandoor-33094-1143152253379-1:2, transactionId =
TX:ID:tandoor-33094-1143152253379-1:2:1}
2006-03-24 09:17:47,997 DEBUG [transport.TransportLogger:2   ] RECEIVED:
from: null : Response {commandId = 13, responseRequired = false,
correlationId = 7}
2006-03-24 09:17:47,997 DEBUG [ra.ServerSessionImpl:0        ] run loop end
2006-03-24 09:17:47,997 DEBUG [ra.ServerSessionPoolImpl      ] Session
returned to pool: ServerSessionImpl:0
2006-03-24 09:17:47,997 DEBUG [ra.ServerSessionImpl:0        ] Run finished
2006-03-24 09:17:47,997 DEBUG [ra.ServerSessionImpl:0        ] Work
completed: javax.resource.spi.work.WorkEvent[source=Work
:ServerSessionImpl:0]


But when sending messages from the remote machine, I only get:

2006-03-24 09:21:50,341 DEBUG [transport.TransportLogger:2   ] RECEIVED:
from: null : MessageDispatch {commandId = 15, responseRequired = false,
consumerId = ID:tandoor-33094-1143152253379-1:2:-1:2, destination =
queue://com.mooter.admanager.echo, message = ActiveMQObjectMessage
{commandId = 10, responseRequired = false, messageId =
ID:jms2-53653-1143151927742-1:2:1:1:3, originalDestination = null,
originalTransactionId = null, producerId =
ID:jms2-53653-1143151927742-1:2:1:1, destination =
queue://com.mooter.admanager.echo, transactionId = null, expiration =
1143152431867, timestamp = 1143152510075, arrival = 0, correlationId = null,
replyTo = temp-queue://ID:jms2-53653-1143151927742-1:2:1, persistent =
false, type = null, priority = 4, groupID = null, groupSequence = 0,
targetConsumerId = null, compressed = false, userID = null, content =
org.activeio.ByteSequence@1dcc4cd, marshalledProperties = null,
dataStructure = null, redeliveryCounter = 0, size = 0, properties = null,
readOnlyProperties = false, readOnlyBody = false}, redeliveryCounter = 0}
2006-03-24 09:21:50,341 DEBUG [ra.ServerSessionPoolImpl      ] ServerSession
requested.
2006-03-24 09:21:50,341 DEBUG [ra.ServerSessionPoolImpl      ] Using idle
session: ServerSessionImpl:0
2006-03-24 09:21:50,341 DEBUG [ra.ServerSessionImpl:0        ] Starting run.
2006-03-24 09:21:50,341 DEBUG [ra.ServerSessionImpl:0        ] Work
accepted:
javax.resource.spi.work.WorkEvent[source=org.apache.geronimo.connector.work.GeronimoWorkManager@c5577c]
2006-03-24 09:21:50,342 DEBUG [ra.ServerSessionImpl:0        ] Work started:
javax.resource.spi.work.WorkEvent[source=Work
:ServerSessionImpl:0]2006-03-24 09:21:50,342 DEBUG [ra.ServerSessionImpl:0       
] Running
2006-03-24 09:21:50,342 DEBUG [ra.ServerSessionImpl:0        ] run loop
start
2006-03-24 09:21:50,342 DEBUG [ra.ServerSessionImpl:0        ] run loop end
2006-03-24 09:21:50,342 DEBUG [ra.ServerSessionPoolImpl      ] Session
returned to pool: ServerSessionImpl:0
2006-03-24 09:21:50,342 DEBUG [ra.ServerSessionImpl:0        ] Run finished

Is there anything special I need to set when producer and consumer are on
different machines?

Thanks,

Kim


--
View this message in context: http://www.nabble.com/can-receive-locally-sent-messages-but-can%27t-receive-remote-messages-t1333276.html#a3561921
Sent from the ActiveMQ - User forum at Nabble.com.


Re: can receive locally sent messages but can't receive remote messages

Posted by Rob Davies <ra...@gmail.com>.
to be compliant with the JMS specification, ActiveMQ uses UTC (though  
I still call it GMT)

cheers,

Rob
On 29 Mar 2006, at 21:39, Kim Pepper wrote:

>
> Also, how does it work with servers in different timezones? Can you  
> specify
> to use UTC?
> --
> View this message in context: http://www.nabble.com/can-receive- 
> locally-sent-messages-but-can%27t-receive-remote-messages- 
> t1333276.html#a3658200
> Sent from the ActiveMQ - User forum at Nabble.com.
>


Re: can receive locally sent messages but can't receive remote messages

Posted by Kim Pepper <ki...@pepper.id.au>.
Also, how does it work with servers in different timezones? Can you specify
to use UTC?
--
View this message in context: http://www.nabble.com/can-receive-locally-sent-messages-but-can%27t-receive-remote-messages-t1333276.html#a3658200
Sent from the ActiveMQ - User forum at Nabble.com.


Re: can receive locally sent messages but can't receive remote messages

Posted by Kim Pepper <ki...@pepper.id.au>.
Turns out the problem was the clocks were out of sync and the expiry date was
set to 5mins. The messages were being expired before they could be consumed.

If the messages are non-durable, how does the expiry work? What is the
default?

Thanks,

Kim

--
View this message in context: http://www.nabble.com/can-receive-locally-sent-messages-but-can%27t-receive-remote-messages-t1333276.html#a3658100
Sent from the ActiveMQ - User forum at Nabble.com.