Package org.openiam.mq.gateway

Class AbstractServiceGateway<Request>

java.lang.Object

org.springframework.amqp.rabbit.core.RabbitGatewaySupport

org.openiam.mq.gateway.AbstractServiceGateway<Request>

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

ConnectorRequestServiceGatewayImpl, RequestServiceGatewayImpl

public abstract class AbstractServiceGateway<Request>
extends org.springframework.amqp.rabbit.core.RabbitGatewaySupport

Created by alexander on 06/07/16.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.commons.logging.Log	log

Fields inherited from class org.springframework.amqp.rabbit.core.RabbitGatewaySupport

logger

Constructor Summary

Constructors

Constructor	Description
AbstractServiceGateway()

Method Summary

Modifier and Type	Method	Description
protected void	convertAndSendWithName(String vhost, String exchange, OpenIAMAPI api, Long delayMillis, Integer priority, Request request, String routingKey)
protected Object	sendAndReceive(String vhost, String exchange, OpenIAMAPI api, Request request, String routingKey)

Methods inherited from class org.springframework.amqp.rabbit.core.RabbitGatewaySupport

afterPropertiesSet, createRabbitTemplate, getConnectionFactory, getRabbitOperations, initGateway, setConnectionFactory, setRabbitOperations

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected final org.apache.commons.logging.Log log

Constructor Detail

AbstractServiceGateway

public AbstractServiceGateway()

Method Detail

convertAndSendWithName

protected void convertAndSendWithName(String vhost,
                                      String exchange,
                                      OpenIAMAPI api,
                                      Long delayMillis,
                                      Integer priority,
                                      Request request,
                                      String routingKey)
                               throws Exception

Throws:

Exception

sendAndReceive

protected Object sendAndReceive(String vhost,
                                String exchange,
                                OpenIAMAPI api,
                                Request request,
                                String routingKey)