|
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(com.rabbitmq.client.Connection con)
Create a RabbitMQ Channel for the given Connection. |
protected com.rabbitmq.client.Connection |
createConnection()
Create a RabbitMQ Connection via this template's ConnectionFactory and its host and port values. |
ConnectionFactory |
getConnectionFactory()
Return the ConnectionFactory that this accessor uses for obtaining RabbitMQ Connections. |
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 com.rabbitmq.client.Connection createConnection()
throws IOException
IOException - if thrown by RabbitMQ API methodsConnectionFactory#newConnection(String, int)
protected com.rabbitmq.client.Channel createChannel(com.rabbitmq.client.Connection con)
throws IOException
con - the RabbitMQ Connection to create a Channel for
IOException - if thrown by RabbitMQ API methodsprotected AmqpException convertRabbitAccessException(Exception ex)
|
Spring AMQP | |||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||