activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: Broker does not receive messages
Date Wed, 27 Sep 2006 13:03:25 GMT
You're gonna kick yourself. You've created a transactional session and
not commit()'d the session. No messages are sent until you commit :)

On 9/27/06, C. Benson Manica <ataru@sdf.lonestar.org> wrote:
> I am running a broker and a message sender on the same machine, and no
> matter what I do, I cannot see any messages enqueued on the broker
> when I view it with JConsole.  On the sender side, the trace debug
> looks like what's show below.  Clearly the sender is talking to
> SOMETHING at localhost:61616 and it claims to be sending a text
> message to that something, so why on earth won't the messages show up
> in the broker?  I have spent hours trying to get this to work and I am
> at my wits' end.  What could I be missing?  This is the sender code:
>
> final QueueConnection connection = mqConnectionFactory.createQueueConnection();
> final QueueSession session = connection.createQueueSession(true, Session.AUTO_ACKNOWLEDGE);
> final Queue destination = session.createQueue("Command");
> final QueueSender sender = session.createSender(destination);
> sender.send(session.createTextMessage("Hello, world!"),DeliveryMode.PERSISTENT,Message.DEFAULT_PRIORITY,(long)180000);
> connection.start();
>
> DEBUG: [2006-09-27 08:47:26,751] org.apache.activemq.transport.WireFormatNegotiator(
) - Sending: WireFormatInfo { version=1, properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
> DEBUG: [2006-09-27 08:47:26,751] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: WireFormatInfo { version=1, properties={TightEncodingEnabled=true, TcpNoDelayEnabled=true,
SizePrefixDisabled=false, StackTraceEnabled=true, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
> DEBUG: [2006-09-27 08:47:26,767] org.apache.activemq.transport.tcp.TcpTransport( ) -
TCP consumer thread starting
> DEBUG: [2006-09-27 08:47:26,782] org.apache.activemq.transport.TransportLogger:1( ) -
RECEIVED: from: null : WireFormatInfo { version=1, properties={StackTraceEnabled=true, TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
> DEBUG: [2006-09-27 08:47:26,798] org.apache.activemq.transport.WireFormatNegotiator(
) - Received WireFormat: WireFormatInfo { version=1, properties={StackTraceEnabled=true, TightEncodingEnabled=true,
TcpNoDelayEnabled=true, SizePrefixDisabled=false, MaxInactivityDuration=30000, CacheEnabled=true},
magic=[A,c,t,i,v,e,M,Q]}
> DEBUG: [2006-09-27 08:47:26,798] org.apache.activemq.transport.WireFormatNegotiator(
) - tcp://localhost/127.0.0.1:61616 before negotiation: OpenWireFormat{version=1, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false, sizePrefixDisabled=false}
> DEBUG: [2006-09-27 08:47:26,798] org.apache.activemq.transport.WireFormatNegotiator(
) - tcp://localhost/127.0.0.1:61616 after negotiation: OpenWireFormat{version=1, cacheEnabled=true,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
> DEBUG: [2006-09-27 08:47:26,798] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: ConnectionInfo {commandId = 1, responseRequired = true, connectionId = ID:TBS-675CFA3526E-1871-1159361246454-1:0,
clientId = ID:TBS-675CFA3526E-1871-1159361246454-2:0, userName = null, password = null, brokerPath
= null, brokerMasterConnector = false, manageable = true}
> DEBUG: [2006-09-27 08:47:26,798] org.apache.activemq.transport.TransportLogger:1( ) -
RECEIVED: from: null : BrokerInfo {commandId = 1, responseRequired = false, brokerId = ID:TBS-675CFA3526E-1863-1159361202673-1:0,
brokerURL = tcp://TBS-675CFA3526E:61616, slaveBroker = false, masterBroker = false, faultTolerantConfiguration
= false, peerBrokerInfos = [], brokerName = localhost}
> DEBUG: [2006-09-27 08:47:26,798] org.apache.activemq.transport.TransportLogger:1( ) -
RECEIVED: from: null : Response {commandId = 2, responseRequired = false, correlationId =
1}
> DEBUG: [2006-09-27 08:47:26,814] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: ConsumerInfo {commandId = 2, responseRequired = true, consumerId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:-1:1,
destination = topic://ActiveMQ.Advisory.TempQueue,topic://ActiveMQ.Advisory.TempTopic, prefetchSize
= 1000, maximumPendingMessageLimit = 0, browser = false, dispatchAsync = false, selector =
null, subcriptionName = null, noLocal = true, exclusive = false, retroactive = false, priority
= 0, brokerPath = null, optimizedAcknowledge = false, noRangeAcks = false, additionalPredicate
= null}
> DEBUG: [2006-09-27 08:47:26,814] org.apache.activemq.transport.TransportLogger:1( ) -
RECEIVED: from: null : Response {commandId = 3, responseRequired = false, correlationId =
2}
> DEBUG: [2006-09-27 08:47:26,861] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: SessionInfo {commandId = 3, responseRequired = false, sessionId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:1}
> DEBUG: [2006-09-27 08:47:26,876] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: ProducerInfo {commandId = 4, responseRequired = false, producerId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:1:1,
destination = queue://Commands, brokerPath = null}
> DEBUG: [2006-09-27 08:47:26,907] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: TransactionInfo {commandId = 5, responseRequired = false, type = 0, connectionId
= ID:TBS-675CFA3526E-1871-1159361246454-1:0, transactionId = TX:ID:TBS-675CFA3526E-1871-1159361246454-1:0:1}
> DEBUG: [2006-09-27 08:47:26,907] org.apache.activemq.ActiveMQSession() - Sending message:
ActiveMQTextMessage {commandId = 0, responseRequired = false, messageId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:1:1,
destination = queue://Commands, transactionId = TX:ID:TBS-675CFA3526E-1871-1159361246454-1:0:1,
expiration = 1159361426907, timestamp = 1159361246907, arrival = 0, correlationId = null,
replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence
= 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties
= null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties
= true, readOnlyBody = true, text = Hello, world!}
> DEBUG: [2006-09-27 08:47:26,907] org.apache.activemq.transport.TransportLogger:1( ) -
SENDING: ActiveMQTextMessage {commandId = 6, responseRequired = false, messageId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:1:1:1,
originalDestination = null, originalTransactionId = null, producerId = ID:TBS-675CFA3526E-1871-1159361246454-1:0:1:1,
destination = queue://Commands, transactionId = TX:ID:TBS-675CFA3526E-1871-1159361246454-1:0:1,
expiration = 1159361426907, timestamp = 1159361246907, arrival = 0, correlationId = null,
replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence
= 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties
= null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties
= true, readOnlyBody = true, text = Hello, world!}
>
> --
> C. Benson Manica
> ataru(at)sdf.lonestar.org
>


-- 

James
-------
http://radio.weblogs.com/0112098/

Mime
View raw message