You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by ankursha1 <an...@gmail.com> on 2013/01/16 13:43:19 UTC
Active MQ broker hang when computer name has Japanese/Chinese
character
Hello,
We are trying to use Active MQ for our application.
MQBroker host machine name is NON- ENGLISH. So it can be
Japanese/Chinese/Korea etc.
We have active mq client written in CPP using active CMS library.
Here is the configuration for broker machine
Active MQ : 5.5.1
OS : Windows XP
JRE : 1.6
Computer Name : KOREAN NAME
When client makes a request to create and start connection , it hang and
broker never returns and response.
Here is the code snippet for Client :
activemq::library::ActiveMQCPP::initializeLibrary();
std::auto_ptr<cms::ConnectionFactory>
cf(cms::ConnectionFactory::createCMSConnectionFactory("tcp://xxx.xxx.xxx.xxx:61616"));
m_connection = cf->createConnection();
m_connection->setExceptionListener(this);
m_connection->start();
After start() client hangs
Below is the mq broker debug log when is broker is started
ActiveMQ 5.5.1 JMS Message Broker (localhost) is starting |
org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain
2013-01-16 21:32:53,796 | INFO | For help or more information please see:
http://activemq.apache.org/ | org.apache.activemq.broker.BrokerService |
WrapperSimpleAppMain
2013-01-16 21:32:53,960 | INFO | Listening for connections at:
tcp://0.0.0.0:61616 |
org.apache.activemq.transport.TransportServerThreadSupport |
WrapperSimpleAppMain
2013-01-16 21:32:53,960 | INFO | Connector openwire Started |
org.apache.activemq.broker.TransportConnector | WrapperSimpleAppMain
2013-01-16 21:32:53,963 | INFO | ActiveMQ JMS Message Broker (localhost,
ID:내ㅡ두믇-49945-1358339573815-0:1) started |
org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain
Sending: WireFormatInfo { version=7, properties={CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=30000, TightEncodingEnabled=true,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} |
org.apache.activemq.transport.WireFormatNegotiator | ActiveMQ Task-1
2013-01-16 21:33:05,686 | DEBUG | Using min of local: WireFormatInfo {
version=7, properties={CacheSize=1024, CacheEnabled=true,
SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000,
TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
TightEncodingEnabled=true, StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]}
and remote: WireFormatInfo { version=7, properties={CacheSize=1024,
CacheEnabled=true, SizePrefixDisabled=false,
MaxInactivityDurationInitalDelay=10000, TcpNoDelayEnabled=true,
MaxInactivityDuration=30000, TightEncodingEnabled=false,
StackTraceEnabled=true}, magic=[A,c,t,i,v,e,M,Q]} |
org.apache.activemq.transport.InactivityMonitor | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,687 | DEBUG | Received WireFormat: WireFormatInfo {
version=7, properties={CacheSize=1024, CacheEnabled=true,
SizePrefixDisabled=false, MaxInactivityDurationInitalDelay=10000,
TcpNoDelayEnabled=true, MaxInactivityDuration=30000,
TightEncodingEnabled=false, StackTraceEnabled=true},
magic=[A,c,t,i,v,e,M,Q]} |
org.apache.activemq.transport.WireFormatNegotiator | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,687 | DEBUG | tcp:///127.0.0.1:49988 before negotiation:
OpenWireFormat{version=7, cacheEnabled=false, stackTraceEnabled=false,
tightEncodingEnabled=false, sizePrefixDisabled=false} |
org.apache.activemq.transport.WireFormatNegotiator | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,687 | DEBUG | tcp:///127.0.0.1:49988 after negotiation:
OpenWireFormat{version=7, cacheEnabled=true, stackTraceEnabled=true,
tightEncodingEnabled=false, sizePrefixDisabled=false} |
org.apache.activemq.transport.WireFormatNegotiator | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,690 | DEBUG | Setting up new connection id:
ID:내ㅡ두믇-49987-1358339585523-0:1, address: /127.0.0.1:49988 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,697 | DEBUG | Publishing: tcp://0.0.0.0:61616 for broker
transport URI: tcp://0.0.0.0:61616 |
org.apache.activemq.broker.TransportConnector | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,697 | DEBUG | localhost adding destination:
topic://ActiveMQ.Advisory.Connection |
org.apache.activemq.broker.region.AbstractRegion | ActiveMQ Transport:
tcp:///127.0.0.1:49988
2013-01-16 21:33:05,715 | DEBUG | localhost adding consumer:
ID:내ㅡ두믇-49987-1358339585523-0:1:-1:1 for destination:
ActiveMQ.Advisory.TempQueue,ActiveMQ.Advisory.TempTopic |
org.apache.activemq.broker.region.AbstractRegion | ActiveMQ Transport:
tcp:///127.0.0.1:49988
And when client tries to connect to broker :
2013-01-16 21:33:31,421 | DEBUG | tcp:///xxx.xxx.xxx.xxx:54089 before
negotiation: OpenWireFormat{version=7, cacheEnabled=false,
stackTraceEnabled=false, tightEncodingEnabled=false,
sizePrefixDisabled=false} |
org.apache.activemq.transport.WireFormatNegotiator | ActiveMQ Transport:
tcp:///xxx.xxx.xxx.xxx:54089
2013-01-16 21:33:31,421 | DEBUG | tcp:///xxx.xxx.xxx.xxx:54089 after
negotiation: OpenWireFormat{version=6, cacheEnabled=false,
stackTraceEnabled=true, tightEncodingEnabled=true, sizePrefixDisabled=false}
| org.apache.activemq.transport.WireFormatNegotiator | ActiveMQ Transport:
tcp:///xxx.xxx.xxx.xxx:54089
2013-01-16 21:33:31,422 | DEBUG | Setting up new connection id:
ID:내ㅡ두믇-54088-1358339387443-0:0, address: /xxx.xxx.xxx.xxx:54089 |
org.apache.activemq.broker.TransportConnection | ActiveMQ Transport:
tcp:///xxx.xxx.xxx.xxx:54089
2013-01-16 21:33:34,301 | DEBUG | Checkpoint started. |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2013-01-16 21:33:34,348 | DEBUG | Checkpoint done. |
org.apache.activemq.store.kahadb.MessageDatabase | ActiveMQ Journal
Checkpoint Worker
2013-01-16 21:33:35,688 | DEBUG |
org.apache.activemq.transport.InactivityMonitor$2@1c7f37d 10001 ms elapsed
since last write check. | org.apache.activemq.transport.InactivityMonitor |
InactivityMonitor WriteCheck
When we change the active mq broker machine name to english everything works
perfectly but we can not ask every customer to changes there computer name.
This has become a show stopper for us and we will be highly thankful for any
suggestion or workaround to solve the problem.
Please reply..
Thank you!!
--
View this message in context: http://activemq.2283324.n4.nabble.com/Active-MQ-broker-hang-when-computer-name-has-Japanese-Chinese-character-tp4661818.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.