|
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 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 AmqpException convertRabbitAccessException(Exception ex)
|
Spring AMQP | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||