Package | Description |
---|---|
org.apache.qpid.client | |
org.apache.qpid.client.message | |
org.apache.qpid.client.protocol |
Modifier and Type | Class and Description |
---|---|
class |
AMQSession_0_10
This is a 0.10 Session
|
class |
AMQSession_0_8 |
class |
XASessionImpl
This is an implementation of the javax.jms.XASession interface.
|
Modifier and Type | Method and Description |
---|---|
AMQSession |
ChannelToSessionMap.get(int channelId) |
AMQSession |
BasicMessageConsumer.getSession() |
AMQSession |
BasicMessageProducer.getSession()
The session used to create this producer
|
AMQSession |
AMQConnection.getSession(int channelId) |
Modifier and Type | Method and Description |
---|---|
List<AMQSession> |
ChannelToSessionMap.values() |
Modifier and Type | Method and Description |
---|---|
void |
AMQProtocolHandler.closeSession(AMQSession session) |
void |
AMQSession.Dispatchable.dispatch(AMQSession ssn) |
void |
ChannelToSessionMap.put(int channelId,
AMQSession session) |
protected void |
BasicMessageProducer.setSession(AMQSession session) |
Constructor and Description |
---|
BasicMessageConsumer_0_10(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession<?,?> session,
Map<String,Object> rawSelector,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean browseOnly,
boolean autoClose) |
BasicMessageConsumer(int channelId,
AMQConnection connection,
AMQDestination destination,
String messageSelector,
boolean noLocal,
MessageFactoryRegistry messageFactory,
AMQSession session,
Map<String,Object> rawSelector,
int prefetchHigh,
int prefetchLow,
boolean exclusive,
int acknowledgeMode,
boolean browseOnly,
boolean autoClose) |
BasicMessageProducer(org.slf4j.Logger logger,
AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
long producerId,
Boolean immediate,
Boolean mandatory) |
Modifier and Type | Method and Description |
---|---|
AMQSession |
AbstractJMSMessage.getAMQSession() |
AMQSession<?,?> |
AbstractAMQMessageDelegate.getAMQSession() |
AMQSession<?,?> |
AMQMessageDelegate.getAMQSession() |
AMQSession<?,?> |
MessageFactoryRegistry.getSession() |
Modifier and Type | Method and Description |
---|---|
void |
UnprocessedMessage.dispatch(AMQSession ssn) |
static MessageFactoryRegistry |
MessageFactoryRegistry.newDefaultRegistry(AMQSession<?,?> session)
Construct a new registry with the default message factories registered
|
byte[] |
MessageEncryptionHelper.readFromCipherStream(byte[] unencryptedBytes,
Cipher cipher,
AMQSession amqSession) |
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 |
AbstractAMQMessageDelegate.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) |
Constructor and Description |
---|
MessageConverter(AMQSession session,
javax.jms.BytesMessage bytesMessage) |
MessageConverter(AMQSession session,
javax.jms.MapMessage message) |
MessageConverter(AMQSession session,
javax.jms.Message message) |
MessageConverter(AMQSession session,
javax.jms.ObjectMessage origMessage) |
MessageConverter(AMQSession session,
javax.jms.StreamMessage message) |
MessageConverter(AMQSession session,
javax.jms.TextMessage message) |
MessageEncryptionHelper(AMQSession<?,?> session) |
MessageFactoryRegistry(AMQSession<?,?> session) |
Modifier and Type | Method and Description |
---|---|
protected AMQSession |
AMQProtocolSession.getSession(int channelId) |
Modifier and Type | Method and Description |
---|---|
void |
AMQProtocolSession.closeSession(AMQSession<?,?> session)
Starts the process of closing a session
|
Copyright © 2006–2016 The Apache Software Foundation. All rights reserved.