[jira] [Created] (AMQ-5432) Activemq Failover is not working when the remote computer is turned off
Tamilmaran created AMQ-5432: --- Summary: Activemq Failover is not working when the remote computer is turned off Key: AMQ-5432 URL: https://issues.apache.org/jira/browse/AMQ-5432 Project: ActiveMQ Issue Type: Bug Components: Broker Affects Versions: 5.9.1 Environment: activeMQ,NMS Reporter: Tamilmaran we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computer 10.2.152.190,10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is not working for the failover. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (AMQ-5432) Activemq Failover is not working when the remote computer is turned off
[ https://issues.apache.org/jira/browse/AMQ-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-5432: Description: we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is not working for the failover. was: we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computer 10.2.152.190,10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is not working for the failover. Activemq Failover is not working when the remote computer is turned off --- Key: AMQ-5432 URL: https://issues.apache.org/jira/browse/AMQ-5432 Project: ActiveMQ Issue Type: Bug Components: Broker Affects Versions: 5.9.1 Environment: activeMQ,NMS Reporter: Tamilmaran we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is not working for the failover. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (AMQ-5432) Activemq Failover is not working when the remote computer is turned off
[ https://issues.apache.org/jira/browse/AMQ-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-5432: Description: we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is NOT working for the failover. was: we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is not working for the failover. Activemq Failover is not working when the remote computer is turned off --- Key: AMQ-5432 URL: https://issues.apache.org/jira/browse/AMQ-5432 Project: ActiveMQ Issue Type: Bug Components: Broker Affects Versions: 5.9.1 Environment: activeMQ,NMS Reporter: Tamilmaran we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is NOT working for the failover. -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Updated] (AMQ-5432) Activemq Failover is not working when the remote computer is turned off
[ https://issues.apache.org/jira/browse/AMQ-5432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-5432: Description: we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is NOT working for the failover. Following error is thrown in this case:- Thread was being aborted. - mscorlib -at System.Threading.Monitor.Enter(Object obj) at Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.TransportFilter.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.MutexTransport.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.ResponseCorrelator.AsyncRequest(Command command) at Apache.NMS.ActiveMQ.Transport.ResponseCorrelator.Request(Command command, TimeSpan timeout) at Apache.NMS.ActiveMQ.Connection.CheckConnected() at Apache.NMS.ActiveMQ.Connection.Start() at BrokerComm.ChannelManager.CheckConnection() in D:\Projects\MCCWAP\Source\BrokerComm\ChannelManager.cs:line 394 was: we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is NOT working for the failover. Activemq Failover is not working when the remote computer is turned off --- Key: AMQ-5432 URL: https://issues.apache.org/jira/browse/AMQ-5432 Project: ActiveMQ Issue Type: Bug Components: Broker Affects Versions: 5.9.1 Environment: activeMQ,NMS Reporter: Tamilmaran we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is NOT working for the failover. Following error is thrown in this case:- Thread was being aborted. - mscorlib -at System.Threading.Monitor.Enter(Object obj) at Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.TransportFilter.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.MutexTransport.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.ResponseCorrelator.AsyncRequest(Command command) at Apache.NMS.ActiveMQ.Transport.ResponseCorrelator.Request(Command command, TimeSpan timeout) at Apache.NMS.ActiveMQ.Connection.CheckConnected() at Apache.NMS.ActiveMQ.Connection.Start() at BrokerComm.ChannelManager.CheckConnection() in D:\Projects\MCCWAP\Source\BrokerComm\ChannelManager.cs:line 394 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (AMQNET-493) Activemq Failover is not working when the remote computer is turned off
Tamilmaran created AMQNET-493: - Summary: Activemq Failover is not working when the remote computer is turned off Key: AMQNET-493 URL: https://issues.apache.org/jira/browse/AMQNET-493 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ Affects Versions: 1.6.2 Environment: ActiveMQ 5.9.1, NMS 1.6.0, NMS.ActiveMQ 1.6.2 Reporter: Tamilmaran Assignee: Jim Gomes we have used following failover URl:- activemq:failover://(ssl://10.2.114.40:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.152.190:61617?transport.serverName=MCCActiveMQBroker,ssl://10.2.112.178:61617?transport.serverName=MCCActiveMQBroker)?transport.randomize=falsetransport.startupMaxReconnectAttempts=0transport.timeout=5000 If the computer 10.2.114.40 is turned off, then it throws error and connection not created even if the computers 10.2.152.190 and 10.2.112.178 are running. Testcase 1: 10.2.114.40 is ON but stopped ActiveMQ 10.2.152.190 is ON and started ActiveMQ there This case is working for the failover. Testcase 2: 10.2.114.40 is turned OFF 10.2.152.190 is ON and started ActiveMQ there This case is NOT working for the failover. Following error is thrown in this case:- Thread was being aborted. - mscorlib - at System.Threading.Monitor.Enter(Object obj) at Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.TransportFilter.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.MutexTransport.Oneway(Command command) at Apache.NMS.ActiveMQ.Transport.ResponseCorrelator.AsyncRequest(Command command) at Apache.NMS.ActiveMQ.Transport.ResponseCorrelator.Request(Command command, TimeSpan timeout) at Apache.NMS.ActiveMQ.Connection.CheckConnected() at Apache.NMS.ActiveMQ.Connection.Start() at BrokerComm.ChannelManager.CheckConnection() in D:\Projects\MCCWAP\Source\BrokerComm\ChannelManager.cs:line 394 -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (AMQ-5392) Active MQ to use multi core processor effectively
Tamilmaran created AMQ-5392: --- Summary: Active MQ to use multi core processor effectively Key: AMQ-5392 URL: https://issues.apache.org/jira/browse/AMQ-5392 Project: ActiveMQ Issue Type: Improvement Affects Versions: 5.9.1 Environment: Multi core processor, ActiveMQ 5.9.1, JVM 7 Reporter: Tamilmaran Priority: Critical It doesn't seem ActiveMQ 5.9.1 uses multi core processor effectively. Will this feature be implemented in later versions? -- This message was sent by Atlassian JIRA (v6.3.4#6332)
[jira] [Created] (AMQ-5254) Hangs the Application if activeMQ is down
Tamilmaran created AMQ-5254: --- Summary: Hangs the Application if activeMQ is down Key: AMQ-5254 URL: https://issues.apache.org/jira/browse/AMQ-5254 Project: ActiveMQ Issue Type: Bug Affects Versions: 5.9.1 Environment: .Net Framework 4.0, ActiveMQ 5.9.1, Apache.NMS.ActiveMQ 1.6.1.3210, Apache.NMS 1.6.1.3083 Reporter: Tamilmaran i am using Topic to publish the message while publishing if activeMQ is down, the application/ control hangs at producer.Send() The control is not coming out of it. It comes when ever activeMQ up again. i am using the below ActiveMQ URI activemq:failover://(ssl://localhost:61617?transport.serverName=someX)?transport.randomize=falseamp;transport.startupMaxReconnectAttempts=0amp;transport.timeout=5000 -- This message was sent by Atlassian JIRA (v6.2#6252)
[jira] [Created] (AMQ-5255) Hangs the Application if activeMQ is down
Tamilmaran created AMQ-5255: --- Summary: Hangs the Application if activeMQ is down Key: AMQ-5255 URL: https://issues.apache.org/jira/browse/AMQ-5255 Project: ActiveMQ Issue Type: Bug Affects Versions: 5.9.1 Environment: .Net Framework 4.0, ActiveMQ 5.9.1, Apache.NMS.ActiveMQ 1.6.1.3210, Apache.NMS 1.6.1.3083 Reporter: Tamilmaran i am using Topic to publish the message while publishing if activeMQ is down, the application/ control hangs at producer.Send() The control is not coming out of it. It comes when ever activeMQ up again. i am using the below ActiveMQ URI activemq:failover://(ssl://localhost:61617?transport.serverName=someX)?transport.randomize=falseamp;transport.startupMaxReconnectAttempts=0amp;transport.timeout=5000 -- This message was sent by Atlassian JIRA (v6.2#6252)
[jira] [Commented] (AMQ-4682) runtime configuration - allow selective application of changes to xml configuration without broker restart
[ https://issues.apache.org/jira/browse/AMQ-4682?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13834800#comment-13834800 ] Tamilmaran commented on AMQ-4682: - By using this configuration can we change the port of transport connector or add a new transport connector? runtime configuration - allow selective application of changes to xml configuration without broker restart -- Key: AMQ-4682 URL: https://issues.apache.org/jira/browse/AMQ-4682 Project: ActiveMQ Issue Type: New Feature Components: Broker Affects Versions: 5.8.0 Reporter: Gary Tully Assignee: Gary Tully Labels: configuration, runtime, updates Fix For: 5.9.0 support on the fly configuration changes where appropriate. Via JMX it is possible to make changes but they don't persist. Via osgi we can restart the broker to pick up changes to xml config but where it makes sense, we should be able to apply changes on the fly. A first example would be the addition on a new network connector by the addition of the relevant xml config (edit or copy over) that is in use by the broker. -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Created] (AMQNET-453) unable to filter the messages with out names space of the TYpe
Tamilmaran created AMQNET-453: - Summary: unable to filter the messages with out names space of the TYpe Key: AMQNET-453 URL: https://issues.apache.org/jira/browse/AMQNET-453 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ, NMS Affects Versions: 1.6.0 Environment: C#-2010 NMS API 1.6.0 Reporter: Tamilmaran Assignee: Jim Gomes we are going to filter messages based on the type sent through NMSType of message header I have 5 classes in two solutions. In both the solutions classes are same but the namespace is different. Publishing side i am sending the NMSType as JackpotHitEvent. but on subscription side it is looking for same with Namespace of the class. so i am unable to filter the messages Example code {code} namespace FloorEventMessagePrototype { public class JackpotHitEvent : FloorEvent, IJackpotHitEvent { } } {code} {code} //for filter i have to give like below or else filter is not working public const string Filter = JMSType = 'FloorEventMessagePrototype.JackpotHitEvent'; {code} -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Updated] (AMQNET-453) unable to filter the messages with out names space of the TYpe
[ https://issues.apache.org/jira/browse/AMQNET-453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQNET-453: -- Description: i am going to use filter in activeMQ based on NMSType of message header i have two solutions with different names(i.e. namesspace). Both the solutions have two same classes like below {code} namespace Publisher { public class HitEvent : FloorEvent, IHitEvent { } } {code} {code} namespace Subscriber { public class HitEvent : FloorEvent, IHitEvent { } } {code} Created Filter as below for the consumer {code} //for filter i have to give like below or else filter is not working public const string Filter = JMSType = 'HitEvent'; {code} but on the consumer side activemq checking for type with names space. so i am not receiving the messages can you help me to work with out names spaces was: we are going to filter messages based on the type sent through NMSType of message header I have 5 classes in two solutions. In both the solutions classes are same but the namespace is different. Publishing side i am sending the NMSType as JackpotHitEvent. but on subscription side it is looking for same with Namespace of the class. so i am unable to filter the messages Example code {code} namespace FloorEventMessagePrototype { public class JackpotHitEvent : FloorEvent, IJackpotHitEvent { } } {code} {code} //for filter i have to give like below or else filter is not working public const string Filter = JMSType = 'FloorEventMessagePrototype.JackpotHitEvent'; {code} unable to filter the messages with out names space of the TYpe -- Key: AMQNET-453 URL: https://issues.apache.org/jira/browse/AMQNET-453 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ, NMS Affects Versions: 1.6.0 Environment: C#-2010 NMS API 1.6.0 Reporter: Tamilmaran Assignee: Jim Gomes i am going to use filter in activeMQ based on NMSType of message header i have two solutions with different names(i.e. namesspace). Both the solutions have two same classes like below {code} namespace Publisher { public class HitEvent : FloorEvent, IHitEvent { } } {code} {code} namespace Subscriber { public class HitEvent : FloorEvent, IHitEvent { } } {code} Created Filter as below for the consumer {code} //for filter i have to give like below or else filter is not working public const string Filter = JMSType = 'HitEvent'; {code} but on the consumer side activemq checking for type with names space. so i am not receiving the messages can you help me to work with out names spaces -- This message was sent by Atlassian JIRA (v6.1#6144)
[jira] [Commented] (AMQNET-440) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQNET-440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13730419#comment-13730419 ] Tamilmaran commented on AMQNET-440: --- Hi Claudio Corsi thanks for your suggestion but there is no method available with name toObject for Body IObjectMessage.ToObjectT is not working - Key: AMQNET-440 URL: https://issues.apache.org/jira/browse/AMQNET-440 Project: ActiveMQ .Net Issue Type: Bug Affects Versions: 1.6.0 Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran Hi I am working on NMS API 1.6.0. i am not able to deserizile using the following object deserilization mechanism objMessage.ToObjectT or objMessage.ToObject() as T Please help us to overcome the issue. Please find our codes below. The code sample: {code} _consumer.Listener += new MessageListener(OnMessage); Employee emp = new Employee(); emp.FirstName = raj; emp.LastName = esh; IObjectMessage objectMessage = producer.CreateObjectMessage(emp); objectMessage.NMSType = emp.GetType().ToString(); producer.Send(objectMessage); {code} {code} protected static void OnMessage(IMessage receivedMsg) { IObjectMessage objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} {code} public interface IEmployee { string FirstName { get; set; } string LastName { get; set; } } {code} {code} [Serializable] public class Employee : IEmployee { #region IEmployee Members private string _firstName; private string _lastName; public string FirstName { get { return this._firstName; } set { this._firstName = value; } } public string LastName { get { return this._lastName; } set { this._lastName = value; } } #endregion } {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-440) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQNET-440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13730421#comment-13730421 ] Tamilmaran commented on AMQNET-440: --- Thanks Jim Gomes Your suggestion is good IObjectMessage.ToObjectT is not working - Key: AMQNET-440 URL: https://issues.apache.org/jira/browse/AMQNET-440 Project: ActiveMQ .Net Issue Type: Bug Affects Versions: 1.6.0 Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran Hi I am working on NMS API 1.6.0. i am not able to deserizile using the following object deserilization mechanism objMessage.ToObjectT or objMessage.ToObject() as T Please help us to overcome the issue. Please find our codes below. The code sample: {code} _consumer.Listener += new MessageListener(OnMessage); Employee emp = new Employee(); emp.FirstName = raj; emp.LastName = esh; IObjectMessage objectMessage = producer.CreateObjectMessage(emp); objectMessage.NMSType = emp.GetType().ToString(); producer.Send(objectMessage); {code} {code} protected static void OnMessage(IMessage receivedMsg) { IObjectMessage objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} {code} public interface IEmployee { string FirstName { get; set; } string LastName { get; set; } } {code} {code} [Serializable] public class Employee : IEmployee { #region IEmployee Members private string _firstName; private string _lastName; public string FirstName { get { return this._firstName; } set { this._firstName = value; } } public string LastName { get { return this._lastName; } set { this._lastName = value; } } #endregion } {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Deleted] (AMQNET-440) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQNET-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQNET-440: -- Comment: was deleted (was: Thanks Jim Gomes Your suggestion is good ) IObjectMessage.ToObjectT is not working - Key: AMQNET-440 URL: https://issues.apache.org/jira/browse/AMQNET-440 Project: ActiveMQ .Net Issue Type: Bug Affects Versions: 1.6.0 Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran Hi I am working on NMS API 1.6.0. i am not able to deserizile using the following object deserilization mechanism objMessage.ToObjectT or objMessage.ToObject() as T Please help us to overcome the issue. Please find our codes below. The code sample: {code} _consumer.Listener += new MessageListener(OnMessage); Employee emp = new Employee(); emp.FirstName = raj; emp.LastName = esh; IObjectMessage objectMessage = producer.CreateObjectMessage(emp); objectMessage.NMSType = emp.GetType().ToString(); producer.Send(objectMessage); {code} {code} protected static void OnMessage(IMessage receivedMsg) { IObjectMessage objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} {code} public interface IEmployee { string FirstName { get; set; } string LastName { get; set; } } {code} {code} [Serializable] public class Employee : IEmployee { #region IEmployee Members private string _firstName; private string _lastName; public string FirstName { get { return this._firstName; } set { this._firstName = value; } } public string LastName { get { return this._lastName; } set { this._lastName = value; } } #endregion } {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Deleted] (AMQNET-440) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQNET-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQNET-440: -- Comment: was deleted (was: Hi Claudio Corsi thanks for your suggestion but there is no method available with name toObject for Body) IObjectMessage.ToObjectT is not working - Key: AMQNET-440 URL: https://issues.apache.org/jira/browse/AMQNET-440 Project: ActiveMQ .Net Issue Type: Bug Affects Versions: 1.6.0 Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran Hi I am working on NMS API 1.6.0. i am not able to deserizile using the following object deserilization mechanism objMessage.ToObjectT or objMessage.ToObject() as T Please help us to overcome the issue. Please find our codes below. The code sample: {code} _consumer.Listener += new MessageListener(OnMessage); Employee emp = new Employee(); emp.FirstName = raj; emp.LastName = esh; IObjectMessage objectMessage = producer.CreateObjectMessage(emp); objectMessage.NMSType = emp.GetType().ToString(); producer.Send(objectMessage); {code} {code} protected static void OnMessage(IMessage receivedMsg) { IObjectMessage objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} {code} public interface IEmployee { string FirstName { get; set; } string LastName { get; set; } } {code} {code} [Serializable] public class Employee : IEmployee { #region IEmployee Members private string _firstName; private string _lastName; public string FirstName { get { return this._firstName; } set { this._firstName = value; } } public string LastName { get { return this._lastName; } set { this._lastName = value; } } #endregion } {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQNET-440) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQNET-440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQNET-440: -- Description: Hi I am working on NMS API 1.6.0. i am not able to deserizile using the following object deserilization mechanism objMessage.ToObjectT or objMessage.ToObject() as T Please help us to overcome the issue. Please find our codes below. The code sample: {code} _consumer.Listener += new MessageListener(OnMessage); Employee emp = new Employee(); emp.FirstName = raj; emp.LastName = esh; IObjectMessage objectMessage = producer.CreateObjectMessage(emp); objectMessage.NMSType = emp.GetType().ToString(); producer.Send(objectMessage); {code} {code} protected static void OnMessage(IMessage receivedMsg) { IObjectMessage objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} {code} public interface IEmployee { string FirstName { get; set; } string LastName { get; set; } } {code} {code} [Serializable] public class Employee : IEmployee { #region IEmployee Members private string _firstName; private string _lastName; public string FirstName { get { return this._firstName; } set { this._firstName = value; } } public string LastName { get { return this._lastName; } set { this._lastName = value; } } #endregion } {code} was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: {code} protected static void OnMessage(IMessage receivedMsg) { objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} IObjectMessage.ToObjectT is not working - Key: AMQNET-440 URL: https://issues.apache.org/jira/browse/AMQNET-440 Project: ActiveMQ .Net Issue Type: Bug Affects Versions: 1.6.0 Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran Hi I am working on NMS API 1.6.0. i am not able to deserizile using the following object deserilization mechanism objMessage.ToObjectT or objMessage.ToObject() as T Please help us to overcome the issue. Please find our codes below. The code sample: {code} _consumer.Listener += new MessageListener(OnMessage); Employee emp = new Employee(); emp.FirstName = raj; emp.LastName = esh; IObjectMessage objectMessage = producer.CreateObjectMessage(emp); objectMessage.NMSType = emp.GetType().ToString(); producer.Send(objectMessage); {code} {code} protected static void OnMessage(IMessage receivedMsg) { IObjectMessage objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } {code} {code} public interface IEmployee { string FirstName { get; set; } string LastName { get; set; } } {code} {code} [Serializable] public class Employee : IEmployee { #region IEmployee Members private string _firstName; private string _lastName; public string FirstName { get { return this._firstName; } set { this._firstName = value; } } public string LastName { get { return this._lastName; } set { this._lastName = value; } } #endregion } {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA,
[jira] [Commented] (AMQNET-441) unable to create a connection using stomp
[ https://issues.apache.org/jira/browse/AMQNET-441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13723698#comment-13723698 ] Tamilmaran commented on AMQNET-441: --- We tried that also already but it is not working.. unable to create a connection using stomp - Key: AMQNET-441 URL: https://issues.apache.org/jira/browse/AMQNET-441 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ Affects Versions: 1.6.0 Environment: ActiveMQ 5.8.0 and NMS API 1.6.0.3061 Reporter: Tamilmaran Assignee: Jim Gomes used the following code to connect with stomp but i am getting the error like Error creating transport. {code} Uri connecturi = new Uri(activemq:stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); using (IConnection connection = factory.CreateConnection()) {code} if i used code as below i am getting the error as No IConnectionFactory implementation found for connection URI: stomp://localhost:61613/ {code} Uri connecturi = new Uri(stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-441) unable to create a connection using stomp
[ https://issues.apache.org/jira/browse/AMQNET-441?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13723700#comment-13723700 ] Tamilmaran commented on AMQNET-441: --- we are getting the following error No IConnectionFactory implementation found for connection URI: stomp:tcp://127.0.0.1:61613 unable to create a connection using stomp - Key: AMQNET-441 URL: https://issues.apache.org/jira/browse/AMQNET-441 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ Affects Versions: 1.6.0 Environment: ActiveMQ 5.8.0 and NMS API 1.6.0.3061 Reporter: Tamilmaran Assignee: Jim Gomes used the following code to connect with stomp but i am getting the error like Error creating transport. {code} Uri connecturi = new Uri(activemq:stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); using (IConnection connection = factory.CreateConnection()) {code} if i used code as below i am getting the error as No IConnectionFactory implementation found for connection URI: stomp://localhost:61613/ {code} Uri connecturi = new Uri(stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Reopened] (AMQNET-441) unable to create a connection using stomp
[ https://issues.apache.org/jira/browse/AMQNET-441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran reopened AMQNET-441: --- we are tried as you said like {code} Uri connecturi = new Uri(stomp:tcp://127.0.0.1:61613); {code} but we are getting the error like below No IConnectionFactory implementation found for connection URI: stomp:tcp://127.0.0.1:61613 unable to create a connection using stomp - Key: AMQNET-441 URL: https://issues.apache.org/jira/browse/AMQNET-441 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ Affects Versions: 1.6.0 Environment: ActiveMQ 5.8.0 and NMS API 1.6.0.3061 Reporter: Tamilmaran Assignee: Jim Gomes used the following code to connect with stomp but i am getting the error like Error creating transport. {code} Uri connecturi = new Uri(activemq:stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); using (IConnection connection = factory.CreateConnection()) {code} if i used code as below i am getting the error as No IConnectionFactory implementation found for connection URI: stomp://localhost:61613/ {code} Uri connecturi = new Uri(stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); {code} -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (AMQNET-441) unable to create a connection using stomp
Tamilmaran created AMQNET-441: - Summary: unable to create a connection using stomp Key: AMQNET-441 URL: https://issues.apache.org/jira/browse/AMQNET-441 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ Affects Versions: 1.6.0 Environment: ActiveMQ 5.8.0 and NMS API 1.6.0.3061 Reporter: Tamilmaran Assignee: Jim Gomes Fix For: 1.6.0 using the following code to connect with stomp but i am getting the following error {code} Uri connecturi = new Uri(activemq:stomp://localhost:61613); IConnectionFactory factory = new NMSConnectionFactory(connecturi); using (IConnection connection = factory.CreateConnection()) {code} Error creating transport. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (AMQ-4653) IObjectMessage.ToObjectT is not working
Tamilmaran created AMQ-4653: --- Summary: IObjectMessage.ToObjectT is not working Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { //Following code is working iEmp = objMessage.Body as IEmployee; } } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4653) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQ-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4653: Description: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { //Following code is working iEmp = objMessage.Body as IEmployee; } } was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { //Following code is working iEmp = objMessage.Body as IEmployee; } } IObjectMessage.ToObjectT is not working - Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { //Following code is working iEmp = objMessage.Body as IEmployee; } } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4653) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQ-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4653: Description: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { iEmp = objMessage.Body as IEmployee;//This code is working } } was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { //Following code is working iEmp = objMessage.Body as IEmployee; } } IObjectMessage.ToObjectT is not working - Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { iEmp = objMessage.Body as IEmployee;//This code is working } } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4653) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQ-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4653: Description: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } IObjectMessage.ToObjectT is not working - Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4653) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQ-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4653: Description: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { IEmployee iEmp = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; if (objMessage != null) { iEmp = objMessage.Body as IEmployee;//This code is working } } IObjectMessage.ToObjectT is not working - Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { = null; objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4653) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQ-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4653: Description: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { bq. objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } IObjectMessage.ToObjectT is not working - Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4653) IObjectMessage.ToObjectT is not working
[ https://issues.apache.org/jira/browse/AMQ-4653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4653: Description: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { bq. objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } was: IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } IObjectMessage.ToObjectT is not working - Key: AMQ-4653 URL: https://issues.apache.org/jira/browse/AMQ-4653 Project: ActiveMQ Issue Type: Bug Environment: activeMQ 5.8.0, C# API NMS 1.6.0 Reporter: Tamilmaran IObjectMessage.ToObjectT is not working to achieve deserialization. The code sample: protected static void OnMessage(IMessage receivedMsg) { bq. objMessage = receivedMsg as IObjectMessage; //Following code is not working IEmployee emp = objMessage.ToObjectIEmployee(); //Following code is not working IEmployee emp1 = objMessage.ToObject() as IEmployee; //Following code is working IEmployee iEmp = objMessage.Body as IEmployee;//This code only is working } -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: (was: Test2-activemq.log) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: Test2-activemq.log SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: Test2-activemq.log Two producers(10.2.44.73,10.2.44.80)each push 500msg/4sec to server(10.11.146.197) The second test but with different error logs. Might be a memory issue? SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar, Test2-activemq.log I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13587042#comment-13587042 ] Tamilmaran commented on AMQ-4336: - System configuration (in which ActiveMQ runs):- Processor: Intel(R) Xeon(TM) CPU 2.80GHz, 2793 Mhz, 1 Core(s), 2 Logical Processor(s) OS Name:Microsoft Windows Server 2008 R2 Standard RAM:2GB System Type:x64-based PC System Name:INCHN-MCC01 SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar, Test2-activemq.log I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586817#comment-13586817 ] Tamilmaran commented on AMQ-4336: - I have set producer window size to Maximum(65535).And i come back to you after testing it. SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: (was: WAPSimulator.rar) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: SimulatorTC.rar Bulk Message Producer SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: activemq.log Broker Log SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: (was: SimulatorTC.rar) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: SimulatorTC.rar Bulk Message Producer SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Deleted] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Comment: was deleted (was: Bulk Message Producer) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Deleted] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Comment: was deleted (was: Bulk Message Simulator-ActiveMQ Producer) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586869#comment-13586869 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 6:49 AM: -- Modified Bulk Message Producer was (Author: tamilmaran): Bulk Message Producer SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586874#comment-13586874 ] Tamilmaran commented on AMQ-4336: - After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stops publishing. Following log is from Producer:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Deleted] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Comment: was deleted (was: Modified Bulk Message Producer) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: (was: SimulatorTC.rar) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: SimulatorTC.rar Modified Bulk Message Producer SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Issue Comment Deleted] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Comment: was deleted (was: After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stops publishing. Following log is from Producer:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted ) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586877#comment-13586877 ] Tamilmaran commented on AMQ-4336: - After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stopped publishing. Following log is from Producer:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586877#comment-13586877 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 6:57 AM: -- After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stopped publishing. Following is the producer log:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted was (Author: tamilmaran): After setting the producer window size to Max,it seems running yesterday night. but when i see it in the morning,consumer is not getting any msg from producer i.e.,producer stopped publishing. Following log is from Producer:- 2013-02-25 18:44:41,976: DEBUG – Broker Started 2013-02-25 18:44:41,992: DEBUG – Simulator started. 2013-02-25 18:44:42,429: DEBUG – Hello Request sent for SMS Casino ID: 194 2013-02-25 18:44:42,539: DEBUG – Hello Request sent for SMS Casino ID: 195 2013-02-25 18:44:44,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-25 18:44:45,195: DEBUG – StartUp Done Msg Received. Slot Count: 250 2013-02-26 06:20:10,070: DEBUG – Broker Interrupted SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586886#comment-13586886 ] Tamilmaran commented on AMQ-4336: - At the time of testing, connectionInterruptedListener and connectionResumedListener are like below:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586886#comment-13586886 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 7:21 AM: -- At the time of testing, connectionInterruptedListener and connectionResumedListener were like below:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } Now i changed it like below and started testing again:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); this.firstConnectionAttemptFailed = true; } private void connectionResumedListener() { Logger.AddBebug(Broker Resumed); if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); Logger.AddBebug(Broker Resumed and restarted); } } was (Author: tamilmaran): At the time of testing, connectionInterruptedListener and connectionResumedListener are like below:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13586886#comment-13586886 ] Tamilmaran edited comment on AMQ-4336 at 2/26/13 7:22 AM: -- At the time of testing, connectionInterruptedListener and connectionResumedListener were like below:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } Now i changed it like below and started testing again:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); this.firstConnectionAttemptFailed = true; } private void connectionResumedListener() { Logger.AddBebug(Broker Resumed); if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); Logger.AddBebug(Broker Resumed and restarted); } } was (Author: tamilmaran): At the time of testing, connectionInterruptedListener and connectionResumedListener were like below:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); } private void connectionResumedListener() { if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); } } Now i changed it like below and started testing again:- private void connectionInterruptedListener() { Logger.AddBebug(Broker Interrupted); this.firstConnectionAttemptFailed = true; } private void connectionResumedListener() { Logger.AddBebug(Broker Resumed); if (this.firstConnectionAttemptFailed) { this.OpenBrokerConnection(); this.AddChannels(this.protocolSettings.channelBlocks); Logger.AddBebug(Broker Resumed and restarted); } } SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.log, activemq.xml, SimulatorTC.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: WAPSimulator.rar Bulk Message Simulator-ActiveMQ Producer Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Description: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) was: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Description: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) was: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Summary: SocketException: Connection reset exception occurred in ActiveMQ for Bulk msg producer (was: Connection reset exception occurred on Bulk msg producer) SocketException: Connection reset exception occurred in ActiveMQ for Bulk msg producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Summary: SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer (was: SocketException: Connection reset exception occurred in ActiveMQ for Bulk msg producer) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Priority: Blocker (was: Major) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Description: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) was: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) SocketException: Connection reset exception occurred in ActiveMQ for Bulk message producer -- Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Priority: Blocker Attachments: activemq.xml, WAPSimulator.rar I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. And a durable subscriber in server side but not sure about its speed to consume all the messages in same rate as well as the producer. But after an hour, 'Connection is already closed' error is logged on producer side. On ActiveMQ side, Following error has been logged. 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config file and producer app(WAPSimulator) -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
Tamilmaran created AMQ-4336: --- Summary: Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. ActiveMQ configuration: beans xmlns=http://www.springframework.org/schema/beans; xmlns:amq=http://activemq.apache.org/schema/core; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation=http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd; bean class=org.springframework.beans.factory.config.PropertyPlaceholderConfigurer property name=locations valuefile:${activemq.conf}/credentials.properties/value /property /bean broker xmlns=http://activemq.apache.org/schema/core; brokerName=localhost dataDirectory=${activemq.data} offlineDurableSubscriberTimeout=2160 offlineDurableSubscriberTaskSchedule=180 destinationPolicy policyMap policyEntries policyEntry topic=gt; producerFlowControl=false memoryLimit=900mb pendingSubscriberPolicy vmCursor/ /pendingSubscriberPolicy pendingDurableSubscriberPolicy fileDurableSubscriberCursor/ /pendingDurableSubscriberPolicy /policyEntry policyEntry queue=gt; producerFlowControl=false memoryLimit=20mb /policyEntry /policyEntries /policyMap /destinationPolicy managementContext managementContext createConnector=false/ /managementContext persistenceAdapter kahaDB ignoreMissingJournalfiles=true directory=${activemq.data}/kahadb/ /persistenceAdapter systemUsage systemUsage sendFailIfNoSpaceAfterTimeout=15000 memoryUsage memoryUsage limit=900 mb/ /memoryUsage storeUsage storeUsage limit=100 gb/ /storeUsage tempUsage tempUsage limit=50 gb/ /tempUsage /systemUsage /systemUsage sslContext sslContext keyStore=file:${activemq.conf}\broker.ks keyStorePassword=HVObfvBd@zDo trustStore=file:${activemq.conf}\client.ks trustStorePassword=HVObfvBd@zDo/ /sslContext transportConnectors transportConnector name=openwire uri=tcp://0.0.0.0:61616/ transportConnector name=ssl uri=ssl://0.0.0.0:61617/ transportConnector name=stomp uri=stomp://0.0.0.0:61613/ transportConnector name=stompssl uri=stomp+ssl://0.0.0.0:61614/ /transportConnectors /broker import resource=jetty.xml/ /beans -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Attachment: activemq.xml Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. ActiveMQ configuration: beans xmlns=http://www.springframework.org/schema/beans; xmlns:amq=http://activemq.apache.org/schema/core; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation=http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd; bean class=org.springframework.beans.factory.config.PropertyPlaceholderConfigurer property name=locations valuefile:${activemq.conf}/credentials.properties/value /property /bean broker xmlns=http://activemq.apache.org/schema/core; brokerName=localhost dataDirectory=${activemq.data} offlineDurableSubscriberTimeout=2160 offlineDurableSubscriberTaskSchedule=180 destinationPolicy policyMap policyEntries policyEntry topic=gt; producerFlowControl=false memoryLimit=900mb pendingSubscriberPolicy vmCursor/ /pendingSubscriberPolicy pendingDurableSubscriberPolicy fileDurableSubscriberCursor/ /pendingDurableSubscriberPolicy /policyEntry policyEntry queue=gt; producerFlowControl=false memoryLimit=20mb /policyEntry /policyEntries /policyMap /destinationPolicy managementContext managementContext createConnector=false/ /managementContext persistenceAdapter kahaDB ignoreMissingJournalfiles=true directory=${activemq.data}/kahadb/ /persistenceAdapter systemUsage systemUsage sendFailIfNoSpaceAfterTimeout=15000 memoryUsage memoryUsage limit=900 mb/ /memoryUsage storeUsage storeUsage limit=100 gb/ /storeUsage tempUsage tempUsage limit=50 gb/ /tempUsage /systemUsage /systemUsage sslContext sslContext keyStore=file:${activemq.conf}\broker.ks keyStorePassword=HVObfvBd@zDo trustStore=file:${activemq.conf}\client.ks trustStorePassword=HVObfvBd@zDo/ /sslContext transportConnectors transportConnector name=openwire uri=tcp://0.0.0.0:61616/ transportConnector name=ssl uri=ssl://0.0.0.0:61617/ transportConnector name=stomp uri=stomp://0.0.0.0:61613/ transportConnector name=stompssl uri=stomp+ssl://0.0.0.0:61614/ /transportConnectors /broker import resource=jetty.xml/ /beans -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Description: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. was: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. ActiveMQ configuration: beans xmlns=http://www.springframework.org/schema/beans; xmlns:amq=http://activemq.apache.org/schema/core; xmlns:xsi=http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation=http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd; bean class=org.springframework.beans.factory.config.PropertyPlaceholderConfigurer property name=locations valuefile:${activemq.conf}/credentials.properties/value /property /bean broker xmlns=http://activemq.apache.org/schema/core; brokerName=localhost dataDirectory=${activemq.data} offlineDurableSubscriberTimeout=2160 offlineDurableSubscriberTaskSchedule=180 destinationPolicy policyMap policyEntries policyEntry topic=gt; producerFlowControl=false memoryLimit=900mb pendingSubscriberPolicy vmCursor/ /pendingSubscriberPolicy pendingDurableSubscriberPolicy fileDurableSubscriberCursor/ /pendingDurableSubscriberPolicy /policyEntry policyEntry queue=gt; producerFlowControl=false memoryLimit=20mb /policyEntry /policyEntries /policyMap /destinationPolicy managementContext managementContext createConnector=false/ /managementContext persistenceAdapter kahaDB ignoreMissingJournalfiles=true directory=${activemq.data}/kahadb/ /persistenceAdapter systemUsage systemUsage sendFailIfNoSpaceAfterTimeout=15000 memoryUsage memoryUsage limit=900 mb/ /memoryUsage storeUsage storeUsage limit=100 gb/ /storeUsage tempUsage tempUsage limit=50 gb/ /tempUsage /systemUsage /systemUsage sslContext sslContext keyStore=file:${activemq.conf}\broker.ks keyStorePassword=HVObfvBd@zDo trustStore=file:${activemq.conf}\client.ks trustStorePassword=HVObfvBd@zDo/ /sslContext transportConnectors transportConnector name=openwire uri=tcp://0.0.0.0:61616/ transportConnector name=ssl uri=ssl://0.0.0.0:61617/ transportConnector name=stomp uri=stomp://0.0.0.0:61613/ transportConnector name=stompssl uri=stomp+ssl://0.0.0.0:61614/ /transportConnectors /broker import resource=jetty.xml/ /beans Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Description: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config was: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (AMQ-4336) Connection reset exception occurred on Bulk msg producer
[ https://issues.apache.org/jira/browse/AMQ-4336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran updated AMQ-4336: Description: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config was: I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73-Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config Connection reset exception occurred on Bulk msg producer Key: AMQ-4336 URL: https://issues.apache.org/jira/browse/AMQ-4336 Project: ActiveMQ Issue Type: Bug Environment: ActiveMQ 5.6,NMS,C# Reporter: Tamilmaran Attachments: activemq.xml I have a Bulk MSG producer which sends 1000 messages for every 4 seconds. But after an hour, Connection reset exception occurred for Bulk MSG producer:- 2013-02-18 21:45:45,149 | WARN | Transport Connection to: tcp://10.2.44.73:59355 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.73:59355 10.2.44.73- Bulk MSG producer IP ActiveMQ is using File based cursor and producer control. Attached activeMQ config -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (AMQNET-408) Bulk message producer is disconnected after a long time
Tamilmaran created AMQNET-408: - Summary: Bulk message producer is disconnected after a long time Key: AMQNET-408 URL: https://issues.apache.org/jira/browse/AMQNET-408 Project: ActiveMQ .Net Issue Type: Bug Components: ActiveMQ, NMS Environment: C#,Windows Server 2008 R2, ActiveMQ version 5.6 Reporter: Tamilmaran Assignee: Jim Gomes I have a producer on client side which publishes 1000 messages every 4 sec. I have enabled producer flow control to false. But still After 2-4 hours, 'The connection is already closed!' errors are logged on producer side and I get the following error on activeMQ : | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-407) if subscriber is stopped publisher also stopped in my app with activemq
[ https://issues.apache.org/jira/browse/AMQNET-407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13570016#comment-13570016 ] Tamilmaran commented on AMQNET-407: --- Thanks after enabling to false, I get the following error on activeMQ after 2 hours 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 if subscriber is stopped publisher also stopped in my app with activemq --- Key: AMQNET-407 URL: https://issues.apache.org/jira/browse/AMQNET-407 Project: ActiveMQ .Net Issue Type: Bug Environment: c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 Reporter: Tamilmaran I studied that in ActiveMQ publisher publishes messages even if there is no subscriber to consume it. But in my application it is not. My server app has a durable subscriber, client app publishes msg to server. If i stopped the server, the client is not publishing any message. When i checked the log it's showing that connection is already closed. What could be the reason for it or any activemq configuration change? I have used c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQNET-407) if subscriber is stopped publisher also stopped in my app with activemq
[ https://issues.apache.org/jira/browse/AMQNET-407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13570016#comment-13570016 ] Tamilmaran edited comment on AMQNET-407 at 2/4/13 6:34 AM: --- Thanks. after enabling to false, I get the following error on activeMQ after 2 hours 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 was (Author: tamilmaran): Thanks after enabling to false, I get the following error on activeMQ after 2 hours 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 if subscriber is stopped publisher also stopped in my app with activemq --- Key: AMQNET-407 URL: https://issues.apache.org/jira/browse/AMQNET-407 Project: ActiveMQ .Net Issue Type: Bug Environment: c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 Reporter: Tamilmaran I studied that in ActiveMQ publisher publishes messages even if there is no subscriber to consume it. But in my application it is not. My server app has a durable subscriber, client app publishes msg to server. If i stopped the server, the client is not publishing any message. When i checked the log it's showing that connection is already closed. What could be the reason for it or any activemq configuration change? I have used c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQNET-407) if subscriber is stopped publisher also stopped in my app with activemq
[ https://issues.apache.org/jira/browse/AMQNET-407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13570016#comment-13570016 ] Tamilmaran edited comment on AMQNET-407 at 2/4/13 6:39 AM: --- Thanks. after enabling to false, The same errors are logged on producer side and I get the following error on activeMQ after 2 hours 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 was (Author: tamilmaran): Thanks. after enabling to false, I get the following error on activeMQ after 2 hours 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 if subscriber is stopped publisher also stopped in my app with activemq --- Key: AMQNET-407 URL: https://issues.apache.org/jira/browse/AMQNET-407 Project: ActiveMQ .Net Issue Type: Bug Environment: c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 Reporter: Tamilmaran I studied that in ActiveMQ publisher publishes messages even if there is no subscriber to consume it. But in my application it is not. My server app has a durable subscriber, client app publishes msg to server. If i stopped the server, the client is not publishing any message. When i checked the log it's showing that connection is already closed. What could be the reason for it or any activemq configuration change? I have used c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQNET-407) if subscriber is stopped publisher also stopped in my app with activemq
[ https://issues.apache.org/jira/browse/AMQNET-407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13570016#comment-13570016 ] Tamilmaran edited comment on AMQNET-407 at 2/4/13 6:56 AM: --- Thanks. But after enabling producer flow control to false, After 2 hours, The same errors are logged on producer side and I get the following error on activeMQ 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 was (Author: tamilmaran): Thanks. after enabling producer flow control to false, After 2 hours, The same errors are logged on producer side and I get the following error on activeMQ 2013-02-01 23:21:21,462 | WARN | Transport Connection to: tcp://10.11.144.68:62749 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.11.144.68:62749 2013-02-01 23:22:22,259 | WARN | Transport Connection to: tcp://10.2.44.80:63051 failed: java.io.EOFException | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: ssl:///10.2.44.80:63051 if subscriber is stopped publisher also stopped in my app with activemq --- Key: AMQNET-407 URL: https://issues.apache.org/jira/browse/AMQNET-407 Project: ActiveMQ .Net Issue Type: Bug Environment: c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 Reporter: Tamilmaran I studied that in ActiveMQ publisher publishes messages even if there is no subscriber to consume it. But in my application it is not. My server app has a durable subscriber, client app publishes msg to server. If i stopped the server, the client is not publishing any message. When i checked the log it's showing that connection is already closed. What could be the reason for it or any activemq configuration change? I have used c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (AMQ-4290) if subscriber is stopped publisher also stopped in my app with activemq
Tamilmaran created AMQ-4290: --- Summary: if subscriber is stopped publisher also stopped in my app with activemq Key: AMQ-4290 URL: https://issues.apache.org/jira/browse/AMQ-4290 Project: ActiveMQ Issue Type: Bug Environment: c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 Reporter: Tamilmaran I studied that in ActiveMQ publisher publishes messages even if there is no subscriber to consume it. But in my application it is not. My server app has a durable subscriber, client app publishes msg to server. If i stopped the server, the client is not publishing any message. When i checked the log it's showing that connection is already closed. What could be the reason for it or any activemq configuration change? I have used c# code with Apache.NMS and Apache.NMS.ActiveMQ dll ActiveMQ version is 5.6 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-387) no iconnectionfactory implementation found for connection uri
[ https://issues.apache.org/jira/browse/AMQNET-387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13291544#comment-13291544 ] Tamilmaran commented on AMQNET-387: --- Thanks! no iconnectionfactory implementation found for connection uri - Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Closed] (AMQNET-387) no iconnectionfactory implementation found for connection uri
[ https://issues.apache.org/jira/browse/AMQNET-387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tamilmaran closed AMQNET-387. - Resolution: Not A Problem no iconnectionfactory implementation found for connection uri - Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Created] (AMQNET-387) no iconnectionfactory implementation found for connection uri
Tamilmaran created AMQNET-387: - Summary: no iconnectionfactory implementation found for connection uri Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-387) no iconnectionfactory implementation found for connection uri
[ https://issues.apache.org/jira/browse/AMQNET-387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13289309#comment-13289309 ] Tamilmaran commented on AMQNET-387: --- But then how is it working on server side alone without those DLLs? no iconnectionfactory implementation found for connection uri - Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-387) no iconnectionfactory implementation found for connection uri
[ https://issues.apache.org/jira/browse/AMQNET-387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13289323#comment-13289323 ] Tamilmaran commented on AMQNET-387: --- no, actually in sever side itself, i am using .NET only to connect with broker. There new NMSConnectionFactory(BrokerURI) doesn't throw error. but the same throws this error on client side. no iconnectionfactory implementation found for connection uri - Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-387) no iconnectionfactory implementation found for connection uri
[ https://issues.apache.org/jira/browse/AMQNET-387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13289942#comment-13289942 ] Tamilmaran commented on AMQNET-387: --- Yes,I could see the Apache.NMS.ActiveMQ.dll in the output path on server side as i had referenced it previously. On the client side,it's gone as i cleaned the solution to rebuild it. It is working if i have Apache.NMS.ActiveMQ.dll in the output folder even if i didn't use it. May i know how it is being called internally...? can u get me understand the flow? no iconnectionfactory implementation found for connection uri - Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (AMQNET-387) no iconnectionfactory implementation found for connection uri
[ https://issues.apache.org/jira/browse/AMQNET-387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13289942#comment-13289942 ] Tamilmaran edited comment on AMQNET-387 at 6/6/12 4:35 AM: --- Yes,I could see the Apache.NMS.ActiveMQ.dll in the output path on server side as i had referenced it previously. On the client side,it's gone as i cleaned the solution to rebuild it. It is working if i have Apache.NMS.ActiveMQ.dll in the output folder even if i didn't use it. May i know how it is being called internally...? can u get me understand the flow/architecture? was (Author: tamilmaran): Yes,I could see the Apache.NMS.ActiveMQ.dll in the output path on server side as i had referenced it previously. On the client side,it's gone as i cleaned the solution to rebuild it. It is working if i have Apache.NMS.ActiveMQ.dll in the output folder even if i didn't use it. May i know how it is being called internally...? can u get me understand the flow? no iconnectionfactory implementation found for connection uri - Key: AMQNET-387 URL: https://issues.apache.org/jira/browse/AMQNET-387 Project: ActiveMQ .Net Issue Type: Bug Reporter: Tamilmaran Assignee: Jim Gomes I'm facing the no iconnectionfactory implementation found for connection uri issue on the client system.The server side which has the broker into it, is running perfectly for topic/queue pub/sub.But the client is not working. I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (AMQNET-249) Is API Receive having ordering problem?
[ https://issues.apache.org/jira/browse/AMQNET-249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13289158#comment-13289158 ] Tamilmaran commented on AMQNET-249: --- How did you fix it? I'm facing the same issue.I have used only NMS DLL. I am not supposed to use NMS.ActiveMQ DLL. In this case, How to get rid of this issue? Is API Receive having ordering problem? --- Key: AMQNET-249 URL: https://issues.apache.org/jira/browse/AMQNET-249 Project: ActiveMQ .Net Issue Type: Bug Components: NMS Affects Versions: 1.1.0 Environment: ActiveMQ is running on Linunx Ubuntu, VB.NET + Apache.NMS is running on WinXP Reporter: jim yu Assignee: Jim Gomes Fix For: 1.2.0 Original Estimate: 1h Remaining Estimate: 1h Hi, All, If try the following steps, the API receive won't work normally.. 1. have 2 programs, one is sender for sending message to actuvemq, another is receiver for receiving message from activemq. 2. Start a connection from the sender to activemq first. 3. Start a connection from the receiver to qctivemq and call consumer.Receive (API Receive) to wait for retrieving data form activemq. 4. Call request.send (API Send) to send a message to activemq in sender. 5. The data will be drop by activemq but Receiver will never get data from activemq. However, API Receive will work normally if start the receiver first and then start the sender. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira