Package org.openiam.mq.gateway.impl

Class RequestServiceGatewayImpl

java.lang.Object

org.springframework.amqp.rabbit.core.RabbitGatewaySupport

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

org.openiam.mq.gateway.impl.RequestServiceGatewayImpl

All Implemented Interfaces:

RequestServiceGateway, org.springframework.beans.factory.InitializingBean

public class RequestServiceGatewayImpl
extends AbstractServiceGateway<BaseServiceRequest>
implements RequestServiceGateway

Author:

Alexander Dukkardt

Field Summary

Fields inherited from class org.openiam.mq.gateway.AbstractServiceGateway

log

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

logger

Constructor Summary

Constructors

Constructor	Description
RequestServiceGatewayImpl()

Method Summary

Modifier and Type	Method	Description
void	broadcast(String vhost, String exchange, OpenIAMAPI api, BaseServiceRequest request, String routingKey)
protected void	convertAndSendWithName(String vhost, String exchange, OpenIAMAPI api, Long delayMillis, Integer priority, BaseServiceRequest request, String routingKey)
void	publish(MqQueue queue, OpenIAMAPI api, BaseServiceRequest request)
void	schedule(MqQueue queue, OpenIAMAPI api, Long delayMillis, Integer priority, BaseServiceRequest request)
void	schedule(MqQueue queue, OpenIAMAPI api, Long delayMillis, BaseServiceRequest request)
void	send(MqQueue queue, OpenIAMAPI api, BaseServiceRequest request)
Response	sendAndReceive(MqQueue queue, OpenIAMAPI api, BaseServiceRequest request)

Methods inherited from class org.openiam.mq.gateway.AbstractServiceGateway

sendAndReceive

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

Constructor Detail

RequestServiceGatewayImpl

public RequestServiceGatewayImpl()

Method Detail

send

public void send(MqQueue queue,
                 OpenIAMAPI api,
                 BaseServiceRequest request)

Specified by:

send in interface RequestServiceGateway

schedule

public void schedule(MqQueue queue,
                     OpenIAMAPI api,
                     Long delayMillis,
                     BaseServiceRequest request)

Specified by:

schedule in interface RequestServiceGateway

schedule

public void schedule(MqQueue queue,
                     OpenIAMAPI api,
                     Long delayMillis,
                     Integer priority,
                     BaseServiceRequest request)

Specified by:

schedule in interface RequestServiceGateway

publish

public void publish(MqQueue queue,
                    OpenIAMAPI api,
                    BaseServiceRequest request)

Specified by:

publish in interface RequestServiceGateway

broadcast

public void broadcast(String vhost,
                      String exchange,
                      OpenIAMAPI api,
                      BaseServiceRequest request,
                      String routingKey)

Specified by:

broadcast in interface RequestServiceGateway

sendAndReceive

public Response sendAndReceive(MqQueue queue,
                               OpenIAMAPI api,
                               BaseServiceRequest request)

Specified by:

sendAndReceive in interface RequestServiceGateway

Parameters:

queue -

request -

Returns:

convertAndSendWithName

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

Overrides:

convertAndSendWithName in class AbstractServiceGateway<BaseServiceRequest>

Throws:

Exception