You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@qpid.apache.org by Adam Kaminiecki <ad...@dgt.com.pl> on 2010/12/20 23:35:24 UTC
C# client question
Please help me, I know You are going to remove this client but please
help me if you can.
When I'm creating session
session = connections.CreateSession(0);
I'm doing it ok? why after 60 sec get an error Conection lost and need
to reconnect??
Why when I'm trying to send 10 message per secon get another error:
my method to send message:
public void SendMessage(string exchange,string routingKey,object
message,bool presistent)
{
try
{
var mes = new Message();
mes.ClearData();
object[] obj = PackMyMessage(message);
mes.AppendData(obj[1] as byte[]);
mes.MessageProperties.SetContentEncoding(obj[0].ToString());
mes.MessageProperties.SetContentType(obj[0].ToString());
if (presistent)
mes.DeliveryProperties.SetDeliveryMode(MessageDeliveryMode.PERSISTENT);
session.MessageTransfer(exchange, routingKey, mes);
}
catch (Exception e)
{
InvokeErrorMessage(e.Message);
}
Am I doing something wrong?? if I send sigle message it's ok but when I
try send many, no messege are sended.
Im using C++ broker 0.8 and client .net
Is there any method to get single message from declared before queue??
Regards,
Adam
--
This message has been scanned for viruses and
dangerous content by MailScanner, and is
believed to be clean.
Re: C++ broker error
Posted by Alan Conway <ac...@redhat.com>.
On 12/20/2010 06:06 PM, Adam Kaminiecki wrote:
> Hi,
>
> I would like to announce I have just found some error
> Have got 2 C++ brokers working in cluster
>
>
> and one of them just go down
Can you file an iisue at https://issues.apache.org/jira so we can track this?
Attach the qpidd log files, your corosync or openais configuration and logs, and
a description of what your own clients are doing when this happens, if you are
running any qpid management tools at the time etc.
My guess is this is a corosync or openais problem, perhaps a problem with
configuration or the corosync/openais service is shut down somehow. Did you see
the broker working correctly up to some point or did the problem occur
immediately when you tried to use it?
>
> 2010-12-20 23:54:19 debug guest@QPID.1228bb68f-12398-14441-1a789-13775359c9489:
> receiver marked completed: 32 incomplete: { } unknown-completed: { [1,32] }
> 2010-12-20 23:54:19 trace cluster(192.168.44.135:3927 READY) DLVR 6058:
> Frame[BEbe; channel=0; {ClusterConnectionDeliverDoOutputBody: limit=2048; }]
> control 192.168.44.134:457-267
> 2010-12-20 23:54:19 debug Sufficient credit for
> 15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c on
> guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c, have bytes: 4294967295
> msgs: 9884, need 147 bytes
> 2010-12-20 23:54:19 debug Credit allocated for
> 15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c on
> guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c, was bytes: 4294967295
> msgs: 9884 now bytes: 4294967295 msgs: 9883
> 2010-12-20 23:54:19 trace guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c:
> sent cmd 116: {MessageTransferBody:
> destination=15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c; accept-mode=0;
> acquire-mode=0; }
> 2010-12-20 23:54:19 trace guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c:
> sent cmd 116: header (84 bytes); properties={{MessageProperties:
> message-id=49568fee-5825-49b6-beb7-7ca4ee942b44;
> content-type=SerializableObject; content-encoding=SerializableObject;
> application-headers={}; }{DeliveryProperties: exchange=test; routing-key=; }}
> 2010-12-20 23:54:19 trace guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c:
> sent cmd 116: content (63 bytes)
> \x00\x01\x00\x00\x00\xFF\xFF\xFF\xFF\x01\x00\x00\x00\x00\x00\x00\x00\x06\x01\x00\x00\x00'Message
> I...
> 2010-12-20 23:54:19 debug No messages to dispatch on queue
> '15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c'
> 2010-12-20 23:54:19 trace cluster(192.168.44.135:3927 READY) DLVR 6059:
> Frame[BEbe; channel=1; {MessageAcceptBody: transfers={ [116,116] }; }] data
> 192.168.44.134:457-267 read-credit=1
> 2010-12-20 23:54:19 trace guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c:
> recv cmd 123: {MessageAcceptBody: transfers={ [116,116] }; }
> 2010-12-20 23:54:19 debug DeliveryRecord::setEnded() id=116
> 2010-12-20 23:54:19 debug Accepted 116
> 2010-12-20 23:54:19 debug guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c:
> receiver marked completed: 123 incomplete: { } unknown-completed: { [1,123] }
> 2010-12-20 23:54:20 trace Sending cluster timer wakeup
> ManagementAgent::periodicProcessing
> 2010-12-20 23:54:20 trace MCAST Event[192.168.44.135:3927-0 Frame[BEbe;
> channel=0; {ClusterTimerWakeupBody: name=ManagementAgent::periodicProcessing; }]]
> 2010-12-20 23:54:23 warning LinkRegistry timer woken up 2998ms late
> 2010-12-20 23:54:25 debug Exception constructed: Cannot mcast to CPG group
> klaster: library (2)
> 2010-12-20 23:54:25 critical Multicast error: Cannot mcast to CPG group klaster:
> library (2)
> 2010-12-20 23:54:25 notice cluster(192.168.44.135:3927 LEFT) leaving cluster
> klaster
> 2010-12-20 23:54:25 trace SEND raiseEvent (v1)
> class=org.apache.qpid.broker.clientDisconnect
> 2010-12-20 23:54:25 trace SEND raiseEvent (v1)
> class=org.apache.qpid.broker.clientDisconnect
> 2010-12-20 23:54:25 trace SEND raiseEvent (v1)
> class=org.apache.qpid.broker.clientDisconnect
> 2010-12-20 23:54:25 debug Shutting down CPG
> 2010-12-20 23:54:26 notice Shut down
>
> I hope this log will be helpfull.
>
> Regards,
> Adam
>
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org
C++ broker error
Posted by Adam Kaminiecki <ad...@dgt.com.pl>.
Hi,
I would like to announce I have just found some error
Have got 2 C++ brokers working in cluster
and one of them just go down
2010-12-20 23:54:19 debug
guest@QPID.1228bb68f-12398-14441-1a789-13775359c9489: receiver marked
completed: 32 incomplete: { } unknown-completed: { [1,32] }
2010-12-20 23:54:19 trace cluster(192.168.44.135:3927 READY) DLVR 6058:
Frame[BEbe; channel=0; {ClusterConnectionDeliverDoOutputBody:
limit=2048; }] control 192.168.44.134:457-267
2010-12-20 23:54:19 debug Sufficient credit for
15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c on
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c, have bytes:
4294967295 msgs: 9884, need 147 bytes
2010-12-20 23:54:19 debug Credit allocated for
15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c on
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c, was bytes:
4294967295 msgs: 9884 now bytes: 4294967295 msgs: 9883
2010-12-20 23:54:19 trace
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c: sent cmd 116:
{MessageTransferBody:
destination=15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c; accept-mode=0;
acquire-mode=0; }
2010-12-20 23:54:19 trace
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c: sent cmd 116:
header (84 bytes); properties={{MessageProperties:
message-id=49568fee-5825-49b6-beb7-7ca4ee942b44;
content-type=SerializableObject; content-encoding=SerializableObject;
application-headers={}; }{DeliveryProperties: exchange=test;
routing-key=; }}
2010-12-20 23:54:19 trace
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c: sent cmd 116:
content (63 bytes)
\x00\x01\x00\x00\x00\xFF\xFF\xFF\xFF\x01\x00\x00\x00\x00\x00\x00\x00\x06\x01\x00\x00\x00'Message
I...
2010-12-20 23:54:19 debug No messages to dispatch on queue
'15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c'
2010-12-20 23:54:19 trace cluster(192.168.44.135:3927 READY) DLVR 6059:
Frame[BEbe; channel=1; {MessageAcceptBody: transfers={ [116,116] }; }]
data 192.168.44.134:457-267 read-credit=1
2010-12-20 23:54:19 trace
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c: recv cmd 123:
{MessageAcceptBody: transfers={ [116,116] }; }
2010-12-20 23:54:19 debug DeliveryRecord::setEnded() id=116
2010-12-20 23:54:19 debug Accepted 116
2010-12-20 23:54:19 debug
guest@QPID.15c72e661-1a54d-14663-1b3cf-1dfc4e7d90e0c: receiver marked
completed: 123 incomplete: { } unknown-completed: { [1,123] }
2010-12-20 23:54:20 trace Sending cluster timer wakeup
ManagementAgent::periodicProcessing
2010-12-20 23:54:20 trace MCAST Event[192.168.44.135:3927-0 Frame[BEbe;
channel=0; {ClusterTimerWakeupBody:
name=ManagementAgent::periodicProcessing; }]]
2010-12-20 23:54:23 warning LinkRegistry timer woken up 2998ms late
2010-12-20 23:54:25 debug Exception constructed: Cannot mcast to CPG
group klaster: library (2)
2010-12-20 23:54:25 critical Multicast error: Cannot mcast to CPG group
klaster: library (2)
2010-12-20 23:54:25 notice cluster(192.168.44.135:3927 LEFT) leaving
cluster klaster
2010-12-20 23:54:25 trace SEND raiseEvent (v1)
class=org.apache.qpid.broker.clientDisconnect
2010-12-20 23:54:25 trace SEND raiseEvent (v1)
class=org.apache.qpid.broker.clientDisconnect
2010-12-20 23:54:25 trace SEND raiseEvent (v1)
class=org.apache.qpid.broker.clientDisconnect
2010-12-20 23:54:25 debug Shutting down CPG
2010-12-20 23:54:26 notice Shut down
I hope this log will be helpfull.
Regards,
Adam
--
This message has been scanned for viruses and
dangerous content by MailScanner, and is
believed to be clean.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:dev-subscribe@qpid.apache.org