activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <gary.tu...@gmail.com>
Subject Re: Active MQ broker hang when computer name has Japanese/Chinese character
Date Thu, 17 Jan 2013 20:50:28 GMT
can you enable trace level logging on the broker and try running the
example java producer, ant producer
There is no indication of a failure in the above logs so maybe trace will
show up something.


On 16 January 2013 12:49, ankursha1 <ankursha1@gmail.com> wrote:

> 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-tp4661819.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>



-- 
http://redhat.com
http://blog.garytully.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message