|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AMQProtocolHandler | |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.failover | |
org.apache.qpid.client.protocol | |
org.apache.qpid.client.transport |
Uses of AMQProtocolHandler in org.apache.qpid.client |
---|
Fields in org.apache.qpid.client declared as AMQProtocolHandler | |
---|---|
protected AMQProtocolHandler |
BasicMessageConsumer._protocolHandler
|
protected AMQProtocolHandler |
BasicMessageProducer._protocolHandler
|
protected AMQProtocolHandler |
AMQConnection._protocolHandler
The protocol handler dispatches protocol events for this connection. |
Methods in org.apache.qpid.client that return AMQProtocolHandler | |
---|---|
protected AMQProtocolHandler |
AMQSession.getProtocolHandler()
|
AMQProtocolHandler |
AMQConnection.getProtocolHandler()
|
Methods in org.apache.qpid.client with parameters of type AMQProtocolHandler | |
---|---|
protected org.apache.qpid.framing.AMQShortString |
AMQSession.declareQueue(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal)
Declares a queue for a JMS destination. |
protected org.apache.qpid.framing.AMQShortString |
AMQSession.declareQueue(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal,
boolean nowait)
|
protected org.apache.qpid.framing.AMQShortString |
AMQSession_0_10.declareQueue(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal,
boolean nowait)
|
org.apache.qpid.framing.AMQShortString |
AMQSession_0_10.send0_10QueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean noLocal,
boolean nowait)
Declare a queue with the given queueName |
void |
AMQSession_0_10.sendConsume(BasicMessageConsumer_0_10 consumer,
org.apache.qpid.framing.AMQShortString queueName,
AMQProtocolHandler protocolHandler,
boolean nowait,
String messageSelector,
int tag)
This method is invoked when a consumer is created Registers the consumer with the broker |
void |
AMQSession_0_8.sendConsume(BasicMessageConsumer_0_8 consumer,
org.apache.qpid.framing.AMQShortString queueName,
AMQProtocolHandler protocolHandler,
boolean nowait,
String messageSelector,
int tag)
|
abstract void |
AMQSession.sendConsume(C consumer,
org.apache.qpid.framing.AMQShortString queueName,
AMQProtocolHandler protocolHandler,
boolean nowait,
String messageSelector,
int tag)
|
abstract void |
AMQSession.sendExchangeDeclare(org.apache.qpid.framing.AMQShortString name,
org.apache.qpid.framing.AMQShortString type,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
void |
AMQSession_0_10.sendExchangeDeclare(org.apache.qpid.framing.AMQShortString name,
org.apache.qpid.framing.AMQShortString type,
AMQProtocolHandler protocolHandler,
boolean nowait)
creates an exchange if it does not already exist |
void |
AMQSession_0_8.sendExchangeDeclare(org.apache.qpid.framing.AMQShortString name,
org.apache.qpid.framing.AMQShortString type,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
abstract void |
AMQSession.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
void |
AMQSession_0_10.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
Declare a queue with the given queueName |
void |
AMQSession_0_8.sendQueueDeclare(AMQDestination amqd,
AMQProtocolHandler protocolHandler,
boolean nowait)
|
Constructors in org.apache.qpid.client with parameters of type AMQProtocolHandler | |
---|---|
BasicMessageConsumer_0_10(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
|
BasicMessageConsumer_0_8(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
|
BasicMessageConsumer(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
AMQProtocolHandler protocolHandler,
org.apache.qpid.framing.FieldTable arguments,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean noConsume,
boolean autoClose)
|
|
BasicMessageProducer_0_10(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
|
BasicMessageProducer_0_8(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
|
BasicMessageProducer(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
Uses of AMQProtocolHandler in org.apache.qpid.client.failover |
---|
Constructors in org.apache.qpid.client.failover with parameters of type AMQProtocolHandler | |
---|---|
FailoverHandler(AMQProtocolHandler amqProtocolHandler)
Creates a failover handler on a protocol session, for a particular MINA session (network connection). |
Uses of AMQProtocolHandler in org.apache.qpid.client.protocol |
---|
Fields in org.apache.qpid.client.protocol declared as AMQProtocolHandler | |
---|---|
protected AMQProtocolHandler |
AMQProtocolSession._protocolHandler
The handler from which this session was created and which is used to handle protocol events. |
Constructors in org.apache.qpid.client.protocol with parameters of type AMQProtocolHandler | |
---|---|
AMQProtocolSession(AMQProtocolHandler protocolHandler,
AMQConnection connection)
|
Uses of AMQProtocolHandler in org.apache.qpid.client.transport |
---|
Methods in org.apache.qpid.client.transport with parameters of type AMQProtocolHandler | |
---|---|
void |
ITransportConnection.connect(AMQProtocolHandler protocolHandler,
BrokerDetails brokerDetail)
|
void |
SocketTransportConnection.connect(AMQProtocolHandler protocolHandler,
BrokerDetails brokerDetail)
|
void |
VmPipeTransportConnection.connect(AMQProtocolHandler protocolHandler,
BrokerDetails brokerDetail)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |