Hi
MyClient=new MessageListener(session);
MyClient.NewMessagee += new
MessageListener.NewMessage(MyClient_NewMessagee);
session.ExchangeDeclare(exchange,type,string.Empty,null,Option.NONE);
string myqueue = session.Name;
session.QueueDeclare(myqueue);
Hi, I get an error in last line i this code:
org.apache.qpid.transport.SessionException was unhandled
Message="System.Collections.Generic.List`1[org.apache.qpid.transport.ExecutionException]"
Source="qpid.client"
Can you give me some advice?
And I have few questions more:
When Im creating sessiom why I must declare expiry in seconds?? Its
timeout for request-response?
Where can I find explanation of patrameters Option??
Is it correct declaration for consumer/message listener or am I doing
something wrong??
private class MessageListener:IMessageListener
{
private readonly ISession session;
public MessageListener(ISession sess)
{
session = sess;
}
public delegate void NewMessage(IMessage e);
public event NewMessage NewMessagee;
public void MessageTransfer(IMessage m)
{
var range = new RangeSet {m.Id};
session.MessageAccept(range,null);
NewMessagee(m);
}
}
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:[email protected]
