You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Czaban <c...@dgt.com.pl> on 2009/08/18 16:09:47 UTC
Code C# form CVS and failover
Hello, J made update of source code form repo and under Windows VS2008 J can
not connect to any working server with uri using failover.
Best regards
Piotr
--
View this message in context: http://www.nabble.com/Code-C--form-CVS-and-failover-tp25025704p25025704.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Code C# form CVS and failover
Posted by Timothy Bish <ta...@gmail.com>.
On Wed, 2009-08-19 at 05:55 -0700, Czaban wrote:
> Post before was wrong, the AMQ client never has success - version form few
> weeks ago works fine.
You should be using the official 1.1.0 release available here, the trunk
code is likely to be unstable as development occurs on that code base.
The release can be downloaded from here:
http://activemq.apache.org/nms/activemq-net-110-release.html
Regards
Tim.
>
>
> [NMS][Info]Connecting to:
> failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
> [NMS][Info]Connecting to:
> failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
> [NMS][Info]Connecting to:
> failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
> [NMS][Debug]Reconnect was triggered but transport is not started yet. Wait
> for start to connect the transport.</RT>
> [NMS][Debug]FailoverTransport Started.</RT>
> [NMS][Debug]Creating reconnect task</RT>
> [NMS][Debug]Waking up reconnect task</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
> protocol.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Waiting 10ms before attempting connection.</RT>
> [NMS][Info]Waiting for transport to reconnect.</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Waiting 20ms before attempting connection.</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with: Apache.NMS.ActiveMQ
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Waiting 40ms before attempting connection.</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Waiting 80ms before attempting connection.</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
> protocol.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Info]Sending queued commands...</RT>
> [NMS][Debug]Parsing type: 2 with:
> Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
> [NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
> not set to an instance of an object.</RT>
> [NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
> [NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
> [NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
> protocol.</RT>
> [NMS][Info]Restoring previous transport connection.</RT>
> [NMS][Debug]Parsing type: 1 with:
> Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
> [NMS][Info]Sending queued commands...</RT>
--
Tim Bish
http://fusesource.com
http://timbish.blogspot.com/
Re: Code C# form CVS and failover
Posted by Czaban <c...@dgt.com.pl>.
Post before was wrong, the AMQ client never has success - version form few
weeks ago works fine.
[NMS][Info]Connecting to:
failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
[NMS][Info]Connecting to:
failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
[NMS][Info]Connecting to:
failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
[NMS][Debug]Reconnect was triggered but transport is not started yet. Wait
for start to connect the transport.</RT>
[NMS][Debug]FailoverTransport Started.</RT>
[NMS][Debug]Creating reconnect task</RT>
[NMS][Debug]Waking up reconnect task</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
protocol.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Waiting 10ms before attempting connection.</RT>
[NMS][Info]Waiting for transport to reconnect.</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Waiting 20ms before attempting connection.</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with: Apache.NMS.ActiveMQ
[NMS][Info]Sending queued commands...</RT>
[NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Waiting 40ms before attempting connection.</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Error]Connect fail to 'tcp://192.168.4.127:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Waiting 80ms before attempting connection.</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.2.206:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.2.206 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.2.206:61616 using InterNetwork
protocol.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Info]Sending queued commands...</RT>
[NMS][Debug]Parsing type: 2 with:
Apache.NMS.ActiveMQ.OpenWire.V2.BrokerInfoMarshaller</RT>
[NMS][Error]Connect fail to 'tcp://192.168.2.206:61616/': Object reference
not set to an instance of an object.</RT>
[NMS][Debug]Attempting connect to: tcp://192.168.4.127:61616/</RT>
[NMS][Debug]Opening socket to: 192.168.4.127 on port: 61616</RT>
[NMS][Debug]Connected to 192.168.4.127:61616 using InterNetwork
protocol.</RT>
[NMS][Info]Restoring previous transport connection.</RT>
[NMS][Debug]Parsing type: 1 with:
Apache.NMS.ActiveMQ.OpenWire.V1.WireFormatInfoMarshaller</RT>
[NMS][Info]Sending queued commands...</RT>
--
View this message in context: http://www.nabble.com/Code-C--form-CVS-and-failover-tp25025704p25043516.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Code C# form CVS and failover
Posted by Czaban <c...@dgt.com.pl>.
Connecting to:
failover:(tcp://192.168.4.127:61616,tcp://192.168.2.206:61616)</RT>
at
Apache.NMS.Tracer.get_IsDebugEnabled() in C:\Users\czaban\Documents\Visual
Studio 2008\Projects\NMS\Apache.NMS\trunk\src\main\csharp\Tracer.cs:line 36
at
Apache.NMS.Tracer.Debug(Object message) in C:\Users\czaban\Documents\Visual
Studio 2008\Projects\NMS\Apache.NMS\trunk\src\main\csharp\Tracer.cs:line 61
at
Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.Reconnect() in
C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\Transport\Failover\FailoverTransport.cs:line
663
at
Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransport.add(Uri[] u) in
C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\Transport\Failover\FailoverTransport.cs:line
600
at
Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransportFactory.CreateTransport(CompositeData
compositData) in C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\Transport\Failover\FailoverTransportFactory.cs:line
52
at
Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransportFactory.doConnect(Uri
location) in C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\Transport\Failover\FailoverTransportFactory.cs:line
28
at
Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransportFactory.CreateTransport(Uri
location) in C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\Transport\Failover\FailoverTransportFactory.cs:line
41
at
Apache.NMS.ActiveMQ.Transport.TransportFactory.CreateTransport(Uri location)
in C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\Transport\TransportFactory.cs:line
47
at
Apache.NMS.ActiveMQ.ConnectionFactory.CreateConnection(String userName,
String password) in C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\ConnectionFactory.cs:line
92
at
Apache.NMS.ActiveMQ.ConnectionFactory.CreateConnection() in
C:\Users\czaban\Documents\Visual Studio
2008\Projects\NMS\Apache.NMS.ActiveMQ\trunk\src\main\csharp\ConnectionFactory.cs:line
81
--
View this message in context: http://www.nabble.com/Code-C--form-CVS-and-failover-tp25025704p25041058.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.