Thanks James, I managed to get it working now. It turned out I changed
different version of activemq.xml file, which is located on different
directory. Silly me!
Anyway, using version 4.0.1 still gives me the same old exception I get when
using 4.0, in my msg producer client. In msg consumer, things look good
though (no exception).
Msg Producer log output:
-------------------------------------------------------------------------------------
Connecting to URL: ssl://localhost:61616
Publishing a Message with size 255 to queue: TOOL.DEFAULT
Using non-durable publishing
Sleeping between publish 0 ms
Sending message: Message: 0 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 1 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 2 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 3 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 4 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 5 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 6 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 7 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 8 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Sending message: Message: 9 sent at: Thu Jul 06 16:23:37 GMT+08:00 ...
Done.
connection {
session {
messageCount{ count: 10 unit: count startTime: 1152174217398
lastSampleTime: 1152174217568 description: Number of messages exchanged }
messageRateTime{ count: 10 maxTime: 100 minTime: 10 totalTime: 150
averageTime: 15.0 averageTimeExMinMax: 5.0 averagePerSecond:
66.66666666666667 averagePerSecondExMinMax: 200.0 unit: millis startTime:
1152174217398 lastSampleTime: 1152174217568 description: Time taken to
process a message (thoughtput rate) }
pendingMessageCount{ count: 0 unit: count startTime: 1152174217398
lastSampleTime: 1152174217398 description: Number of pending messages }
expiredMessageCount{ count: 0 unit: count startTime: 1152174217398
lastSampleTime: 1152174217398 description: Number of expired messages }
messageWaitTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0
averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0
averagePerSecondExMinMax: 0.0 unit: millis startTime: 1152174217398
lastSampleTime: 1152174217398 description: Time spent by a message before
being delivered }
durableSubscriptionCount{ count: 0 unit: count startTime: 1152174217398
lastSampleTime: 1152174217398 description: The number of durable
subscriptions }
producers {
producer queue://TOOL.DEFAULT {
messageCount{ count: 10 unit: count startTime: 1152174217418
lastSampleTime: 1152174217568 description: Number of messages processed }
messageRateTime{ count: 10 maxTime: 100 minTime: 10 totalTime: 150
averageTime: 15.0 averageTimeExMinMax: 5.0 averagePerSecond:
66.66666666666667 averagePerSecondExMinMax: 200.0 unit: millis startTime:
1152174217418 lastSampleTime: 1152174217568 description: Time taken to
process a message (thoughtput rate) }
javax.jms.JMSException: Connection closed by remote host
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:57)
pendingMessageCount{ count: 0 unit: count startTime: 1152174217418
lastSampleTime: 1152174217418 description: Number of pending messages }
messageRateTime{ count: 10 maxTime: 100 minTime: 10 totalTime: 150
averageTime: 15.0 averageTimeExMinMax: 5.0 averagePerSecond:
66.66666666666667 averagePerSecondExMinMax: 200.0 unit: millis startTime:
1152174217418 lastSampleTime: 1152174217568 description: Time taken to
process a message (thoughtput rate) }
expiredMessageCount{ count: 0 unit: count startTime: 1152174217418
lastSampleTime: 1152174217418 description: Number of expired messages }
messageWaitTime{ count: 0 maxTime: 0 minTime: 0 totalTime: 0
averageTime: 0.0 averageTimeExMinMax: 0.0 averagePerSecond: 0.0
averagePerSecondExMinMax: 0.0 unit: millis startTime: 1152174217418
lastSampleTime: 1152174217418 description: Time spent by a message before
being delivered }
}
}
consumers {
}
}
}
Caught: javax.jms.JMSException: Connection closed by remote host
at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1094)
at
org.apache.activemq.ActiveMQConnection.close(ActiveMQConnection.java:565)
at com.ic.ntn.message.MsgSupport.close(MsgSupport.java:75)
at com.ic.ntn.message.MsgProducer.run(MsgProducer.java:100)
at com.ic.ntn.message.MsgProducer.runTool(MsgProducer.java:82)
at com.ic.ntn.message.MsgProducer.main(MsgProducer.java:45)
Caused by: java.net.SocketException: Connection closed by remote host
at
com.sun.net.ssl.internal.ssl.SSLSocketImpl.checkWrite(SSLSocketImpl.java:1187)
at
com.sun.net.ssl.internal.ssl.AppOutputStream.write(AppOutputStream.java:60)
at
org.apache.activemq.transport.tcp.TcpBufferedOutputStream.flush(TcpBufferedOutputStream.java:108)
at java.io.DataOutputStream.flush(DataOutputStream.java:106)
at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:125)
at
org.apache.activemq.transport.InactivityMonitor.oneway(InactivityMonitor.java:141)
at
org.apache.activemq.transport.TransportFilter.oneway(TransportFilter.java:78)
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:77)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
at
org.apache.activemq.ActiveMQConnection.asyncSendPacket(ActiveMQConnection.java:1092)
... 5 more
--
View this message in context:
http://www.nabble.com/Using-SSL-with-AMQ-4.0.1-tf1898836.html#a5195768
Sent from the ActiveMQ - User forum at Nabble.com.
