public class AmqpProxyFactoryBean extends AmqpClientInterceptor implements FactoryBean<Object>, BeanClassLoaderAware, 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
logger
Constructor and Description |
---|
AmqpProxyFactoryBean() |
Modifier and Type | Method and Description |
---|---|
void |
afterPropertiesSet() |
Object |
getObject() |
Class<?> |
getObjectType() |
boolean |
isSingleton() |
getAmqpTemplate, getRemoteInvocationFactory, getRoutingKey, invoke, setAmqpTemplate, setRemoteInvocationFactory, setRoutingKey
getServiceInterface, setServiceInterface
getBeanClassLoader, overrideThreadContextClassLoader, resetThreadContextClassLoader, setBeanClassLoader
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setBeanClassLoader
public void afterPropertiesSet()
afterPropertiesSet
in interface InitializingBean
public Object getObject()
getObject
in interface FactoryBean<Object>
public Class<?> getObjectType()
getObjectType
in interface FactoryBean<Object>
public boolean isSingleton()
isSingleton
in interface FactoryBean<Object>