|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use AMQSession | |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.message | |
org.apache.qpid.client.protocol |
Uses of AMQSession in org.apache.qpid.client |
---|
Subclasses of AMQSession in org.apache.qpid.client | |
---|---|
class |
AMQSession_0_10
This is a 0.10 Session |
class |
AMQSession_0_8
|
class |
XASessionImpl
This is an implementation of the javax.njms.XASEssion interface. |
Fields in org.apache.qpid.client declared as AMQSession | |
---|---|
protected AMQSession |
BasicMessageConsumer._session
|
protected AMQSession |
BasicMessageProducer._session
The session used to create this producer |
protected AMQSession |
AMQQueueSessionAdaptor._session
|
protected AMQSession |
AMQTopicSessionAdaptor._session
|
(package private) AMQSession<C,P> |
AMQSession._thisSession
|
Methods in org.apache.qpid.client that return AMQSession | |
---|---|
AMQSession |
AMQConnection.ChannelToSessionMap.get(int channelId)
|
AMQSession |
BasicMessageConsumer.getSession()
|
AMQSession |
BasicMessageProducer.getSession()
|
AMQSession |
AMQQueueSessionAdaptor.getSession()
|
AMQSession |
AMQSessionAdapter.getSession()
|
AMQSession |
AMQTemporaryQueue.getSession()
|
AMQSession |
TemporaryDestination.getSession()
|
AMQSession |
AMQTemporaryTopic.getSession()
|
AMQSession |
AMQTopicSessionAdaptor.getSession()
|
AMQSession |
AMQConnection.getSession(int channelId)
|
AMQSession |
AMQConnection.ChannelToSessionMap.put(int channelId,
AMQSession session)
|
AMQSession |
AMQConnection.ChannelToSessionMap.remove(int channelId)
|
Methods in org.apache.qpid.client that return types with arguments of type AMQSession | |
---|---|
Collection<AMQSession> |
AMQConnection.ChannelToSessionMap.values()
|
Methods in org.apache.qpid.client with parameters of type AMQSession | |
---|---|
void |
AMQSession.Dispatchable.dispatch(AMQSession ssn)
|
AMQSession |
AMQConnection.ChannelToSessionMap.put(int channelId,
AMQSession session)
|
(package private) void |
AMQConnection.registerSession(int channelId,
AMQSession session)
|
Method parameters in org.apache.qpid.client with type arguments of type AMQSession | |
---|---|
void |
AMQConnection.close(List<AMQSession> sessions,
long timeout)
|
Constructors in org.apache.qpid.client with parameters of type AMQSession | |
---|---|
AMQQueueBrowser(AMQSession session,
AMQQueue queue,
String messageSelector)
|
|
AMQTemporaryQueue(AMQSession session)
Create a new instance of an AMQTemporaryQueue |
|
AMQTemporaryTopic(AMQSession session)
Create new temporary topic. |
|
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 AMQSession in org.apache.qpid.client.message |
---|
Methods in org.apache.qpid.client.message that return AMQSession | |
---|---|
AMQSession |
AbstractJMSMessage.getAMQSession()
|
AMQSession |
AMQMessageDelegate.getAMQSession()
|
AMQSession |
AMQMessageDelegate_0_10.getAMQSession()
|
AMQSession |
AMQMessageDelegate_0_8.getAMQSession()
|
Methods in org.apache.qpid.client.message with parameters of type AMQSession | |
---|---|
void |
UnprocessedMessage.dispatch(AMQSession ssn)
|
void |
AbstractJMSMessage.setAMQSession(AMQSession s)
The session is set when CLIENT_ACKNOWLEDGE mode is used so that the CHANNEL ACK can be sent when the user calls acknowledge() |
void |
AMQMessageDelegate.setAMQSession(AMQSession s)
|
void |
AMQMessageDelegate_0_10.setAMQSession(AMQSession s)
The session is set when CLIENT_ACKNOWLEDGE mode is used so that the CHANNEL ACK can be sent when the user calls acknowledge() |
void |
AMQMessageDelegate_0_8.setAMQSession(AMQSession s)
The session is set when CLIENT_ACKNOWLEDGE mode is used so that the CHANNEL ACK can be sent when the user calls acknowledge() |
Constructors in org.apache.qpid.client.message with parameters of type AMQSession | |
---|---|
MessageConverter(AMQSession session,
BytesMessage bytesMessage)
|
|
MessageConverter(AMQSession session,
MapMessage message)
|
|
MessageConverter(AMQSession session,
Message message)
|
|
MessageConverter(AMQSession session,
ObjectMessage origMessage)
|
|
MessageConverter(AMQSession session,
StreamMessage message)
|
|
MessageConverter(AMQSession session,
TextMessage message)
|
Uses of AMQSession in org.apache.qpid.client.protocol |
---|
Fields in org.apache.qpid.client.protocol with type parameters of type AMQSession | |
---|---|
protected ConcurrentMap<Integer,AMQSession> |
AMQProtocolSession._channelId2SessionMap
Maps from the channel id to the AMQSession that it represents. |
Methods in org.apache.qpid.client.protocol that return AMQSession | |
---|---|
protected AMQSession |
AMQProtocolSession.getSession(int channelId)
|
Methods in org.apache.qpid.client.protocol with parameters of type AMQSession | |
---|---|
void |
AMQProtocolHandler.closeSession(AMQSession session)
|
void |
AMQProtocolSession.closeSession(AMQSession session)
Starts the process of closing a session |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |