public class AmqpProxyFactoryBean extends AmqpClientInterceptor implements FactoryBean<Object>, 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
OBJECT_TYPE_ATTRIBUTE
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
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>