|
Spring AMQP | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.amqp.rabbit.support.RabbitAccessor
public abstract class RabbitAccessor
Field Summary | |
---|---|
protected org.apache.commons.logging.Log |
logger
Logger available to subclasses |
Constructor Summary | |
---|---|
RabbitAccessor()
|
Method Summary | |
---|---|
void |
afterPropertiesSet()
|
protected AmqpException |
convertRabbitAccessException(Exception ex)
|
protected com.rabbitmq.client.Channel |
createChannel(Connection con)
Create a RabbitMQ Channel for the given Connection. |
protected Connection |
createConnection()
Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values. |
protected com.rabbitmq.client.Channel |
getChannel(RabbitResourceHolder holder)
Fetch an appropriate Channel from the given RabbitResourceHolder. |
protected Connection |
getConnection(RabbitResourceHolder holder)
Fetch an appropriate Connection from the given RabbitResourceHolder. |
ConnectionFactory |
getConnectionFactory()
Return the ConnectionFactory that this accessor uses for obtaining RabbitMQ Connections . |
protected RabbitResourceHolder |
getTransactionalResourceHolder()
|
boolean |
isChannelTransacted()
Return whether the RabbitMQ channels used by this
accessor are supposed to be transacted. |
void |
setChannelTransacted(boolean channelTransacted)
Set the transaction mode that is used for a RabbitMQ Channel ,
Default is "false". |
void |
setConnectionFactory(ConnectionFactory connectionFactory)
Set the ConnectionFactory to use for obtaining RabbitMQ Connections . |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final org.apache.commons.logging.Log logger
Constructor Detail |
---|
public RabbitAccessor()
Method Detail |
---|
public void setConnectionFactory(ConnectionFactory connectionFactory)
Connections
.
public ConnectionFactory getConnectionFactory()
Connections
.
public void setChannelTransacted(boolean channelTransacted)
Channel
,
Default is "false".
public boolean isChannelTransacted()
channels
used by this
accessor are supposed to be transacted.
setChannelTransacted(boolean)
public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
protected Connection createConnection() throws IOException
IOException
- if thrown by RabbitMQ API methodsConnectionFactory.createConnection()
protected com.rabbitmq.client.Channel createChannel(Connection con) throws IOException
con
- the RabbitMQ Connection to create a Channel for
IOException
- if thrown by RabbitMQ API methodsprotected Connection getConnection(RabbitResourceHolder holder)
holder
- the RabbitResourceHolder
null
if none foundprotected com.rabbitmq.client.Channel getChannel(RabbitResourceHolder holder)
holder
- the RabbitResourceHolder
null
if none foundprotected RabbitResourceHolder getTransactionalResourceHolder()
protected AmqpException convertRabbitAccessException(Exception ex)
|
Spring AMQP | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |