public class AmqpProxyFactoryBean extends AmqpClientInterceptor implements org.springframework.beans.factory.FactoryBean<java.lang.Object>, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.InitializingBean
FactoryBean for AMQP proxies. Exposes the proxied service for use as a bean reference, using the specified
service interface. Proxies will throw Spring's unchecked RemoteAccessException on remote invocation failure.
This is intended for an "RMI-style" (i.e. synchroneous) usage of the AMQP protocol. Obviously, AMQP allows for a much broader scope of execution styles, which are not the scope of the mechanism at hand.
Calling a method on the proxy will cause an AMQP message being sent according to the configured AmqpTemplate.
This can be received and answered by an AmqpInvokerServiceExporter.
RemoteAccessor.setServiceInterface(java.lang.Class<?>),
AmqpClientInterceptor,
RmiServiceExporter,
RemoteAccessException| Constructor and Description |
|---|
AmqpProxyFactoryBean() |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
java.lang.Object |
getObject() |
java.lang.Class<?> |
getObjectType() |
boolean |
isSingleton() |
getAmqpTemplate, getRemoteInvocationFactory, getRoutingKey, invoke, setAmqpTemplate, setRemoteInvocationFactory, setRoutingKeygetServiceInterface, setServiceInterfacegetBeanClassLoader, overrideThreadContextClassLoader, resetThreadContextClassLoader, setBeanClassLoaderpublic void afterPropertiesSet()
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanpublic java.lang.Object getObject()
throws java.lang.Exception
getObject in interface org.springframework.beans.factory.FactoryBean<java.lang.Object>java.lang.Exceptionpublic java.lang.Class<?> getObjectType()
getObjectType in interface org.springframework.beans.factory.FactoryBean<java.lang.Object>public boolean isSingleton()
isSingleton in interface org.springframework.beans.factory.FactoryBean<java.lang.Object>