|
Spring AMQP | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.springframework.amqp.rabbit.connection.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 RuntimeException |
convertRabbitAccessException(Exception ex)
|
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()
|
void |
setChannelTransacted(boolean transactional)
Flag to indicate that channels created by this component will be transactional. |
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 boolean isChannelTransacted()
public void setChannelTransacted(boolean transactional)
transactional
- the flag value to setpublic void setConnectionFactory(ConnectionFactory connectionFactory)
Connections
.
public ConnectionFactory getConnectionFactory()
Connections
.
public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
protected Connection createConnection() throws IOException
IOException
- if thrown by RabbitMQ API methodsConnectionFactory.createConnection()
protected 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 RuntimeException convertRabbitAccessException(Exception ex)
|
Spring AMQP | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |