INT-1306 renamed AbstractMessagingGateway to MessagingGatewaySupport
This commit is contained in:
@@ -446,7 +446,7 @@ public class GatewayProxyFactoryBean extends AbstractEndpoint implements Trackab
|
||||
}
|
||||
|
||||
|
||||
private static class MethodInvocationGateway extends AbstractMessagingGateway {
|
||||
private static class MethodInvocationGateway extends MessagingGatewaySupport {
|
||||
|
||||
private MethodInvocationGateway(GatewayMethodInboundMessageMapper messageMapper) {
|
||||
this.setRequestMapper(messageMapper);
|
||||
|
||||
@@ -45,7 +45,7 @@ import org.springframework.util.Assert;
|
||||
*
|
||||
* @author Mark Fisher
|
||||
*/
|
||||
public abstract class AbstractMessagingGateway extends AbstractEndpoint implements TrackableComponent {
|
||||
public abstract class MessagingGatewaySupport extends AbstractEndpoint implements TrackableComponent {
|
||||
|
||||
private static final long DEFAULT_TIMEOUT = 1000L;
|
||||
|
||||
@@ -76,7 +76,7 @@ public abstract class AbstractMessagingGateway extends AbstractEndpoint implemen
|
||||
private final Object replyMessageCorrelatorMonitor = new Object();
|
||||
|
||||
|
||||
public AbstractMessagingGateway() {
|
||||
public MessagingGatewaySupport() {
|
||||
MessagingTemplate template = new MessagingTemplate();
|
||||
template.setMessageConverter(this.messageConverter);
|
||||
template.setSendTimeout(DEFAULT_TIMEOUT);
|
||||
@@ -23,7 +23,7 @@ import org.springframework.integration.Message;
|
||||
*
|
||||
* @author Mark Fisher
|
||||
*/
|
||||
public abstract class RemotingInboundGatewaySupport extends AbstractMessagingGateway implements RequestReplyExchanger {
|
||||
public abstract class RemotingInboundGatewaySupport extends MessagingGatewaySupport implements RequestReplyExchanger {
|
||||
|
||||
private volatile boolean expectReply = true;
|
||||
|
||||
|
||||
@@ -48,7 +48,7 @@ import org.springframework.integration.test.util.TestUtils;
|
||||
@SuppressWarnings("unchecked")
|
||||
public class MessagingGatewayTests {
|
||||
|
||||
private volatile AbstractMessagingGateway messagingGateway;
|
||||
private volatile MessagingGatewaySupport messagingGateway;
|
||||
|
||||
private volatile MessageChannel requestChannel = createMock(MessageChannel.class);
|
||||
|
||||
@@ -62,7 +62,7 @@ public class MessagingGatewayTests {
|
||||
|
||||
@Before
|
||||
public void initializeSample() {
|
||||
this.messagingGateway = new AbstractMessagingGateway() {};
|
||||
this.messagingGateway = new MessagingGatewaySupport() {};
|
||||
this.messagingGateway.setRequestChannel(requestChannel);
|
||||
this.messagingGateway.setReplyChannel(replyChannel);
|
||||
this.messagingGateway.setBeanFactory(TestUtils.createTestApplicationContext());
|
||||
|
||||
@@ -40,7 +40,7 @@ public class NestedGatewayTests {
|
||||
return requestMessage.getPayload() + "-reply";
|
||||
}
|
||||
});
|
||||
final AbstractMessagingGateway innerGateway = new AbstractMessagingGateway() {};
|
||||
final MessagingGatewaySupport innerGateway = new MessagingGatewaySupport() {};
|
||||
innerGateway.setRequestChannel(innerChannel);
|
||||
innerGateway.afterPropertiesSet();
|
||||
outerChannel.subscribe(new AbstractReplyProducingMessageHandler() {
|
||||
@@ -50,7 +50,7 @@ public class NestedGatewayTests {
|
||||
"pre-" + requestMessage.getPayload()).getPayload() + "-post";
|
||||
}
|
||||
});
|
||||
AbstractMessagingGateway outerGateway = new AbstractMessagingGateway() {};
|
||||
MessagingGatewaySupport outerGateway = new MessagingGatewaySupport() {};
|
||||
outerGateway.setRequestChannel(outerChannel);
|
||||
outerGateway.afterPropertiesSet();
|
||||
Message<?> reply = outerGateway.sendAndReceiveMessage("test");
|
||||
@@ -67,7 +67,7 @@ public class NestedGatewayTests {
|
||||
return requestMessage.getPayload() + "-reply";
|
||||
}
|
||||
});
|
||||
AbstractMessagingGateway gateway = new AbstractMessagingGateway() {};
|
||||
MessagingGatewaySupport gateway = new MessagingGatewaySupport() {};
|
||||
gateway.setRequestChannel(requestChannel);
|
||||
gateway.afterPropertiesSet();
|
||||
Message<?> message = MessageBuilder.withPayload("test")
|
||||
@@ -87,7 +87,7 @@ public class NestedGatewayTests {
|
||||
return requestMessage.getPayload() + "-reply";
|
||||
}
|
||||
});
|
||||
AbstractMessagingGateway gateway = new AbstractMessagingGateway() {};
|
||||
MessagingGatewaySupport gateway = new MessagingGatewaySupport() {};
|
||||
gateway.setRequestChannel(requestChannel);
|
||||
gateway.afterPropertiesSet();
|
||||
Message<?> message = MessageBuilder.withPayload("test")
|
||||
|
||||
@@ -41,7 +41,7 @@ import org.springframework.http.server.ServletServerHttpRequest;
|
||||
import org.springframework.http.server.ServletServerHttpResponse;
|
||||
import org.springframework.integration.Message;
|
||||
import org.springframework.integration.MessagingException;
|
||||
import org.springframework.integration.gateway.AbstractMessagingGateway;
|
||||
import org.springframework.integration.gateway.MessagingGatewaySupport;
|
||||
import org.springframework.integration.mapping.HeaderMapper;
|
||||
import org.springframework.integration.support.MessageBuilder;
|
||||
import org.springframework.util.Assert;
|
||||
@@ -75,7 +75,7 @@ import org.springframework.web.servlet.DispatcherServlet;
|
||||
* @author Mark Fisher
|
||||
* @since 2.0
|
||||
*/
|
||||
abstract class HttpRequestHandlingEndpointSupport extends AbstractMessagingGateway {
|
||||
abstract class HttpRequestHandlingEndpointSupport extends MessagingGatewaySupport {
|
||||
|
||||
private static final boolean jaxb2Present = ClassUtils.isPresent("javax.xml.bind.Binder",
|
||||
HttpRequestHandlingEndpointSupport.class.getClassLoader());
|
||||
|
||||
@@ -19,7 +19,7 @@ import java.util.Map;
|
||||
import java.util.concurrent.ConcurrentHashMap;
|
||||
|
||||
import org.springframework.integration.Message;
|
||||
import org.springframework.integration.gateway.AbstractMessagingGateway;
|
||||
import org.springframework.integration.gateway.MessagingGatewaySupport;
|
||||
import org.springframework.integration.ip.IpHeaders;
|
||||
import org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory;
|
||||
import org.springframework.integration.ip.tcp.connection.TcpConnection;
|
||||
@@ -38,7 +38,7 @@ import org.springframework.integration.ip.tcp.connection.TcpSender;
|
||||
* @since 2.0
|
||||
*
|
||||
*/
|
||||
public class TcpInboundGateway extends AbstractMessagingGateway implements TcpListener, TcpSender {
|
||||
public class TcpInboundGateway extends MessagingGatewaySupport implements TcpListener, TcpSender {
|
||||
|
||||
protected AbstractServerConnectionFactory connectionFactory;
|
||||
|
||||
|
||||
@@ -27,7 +27,7 @@ import javax.jms.Session;
|
||||
|
||||
import org.springframework.beans.factory.InitializingBean;
|
||||
import org.springframework.integration.Message;
|
||||
import org.springframework.integration.gateway.AbstractMessagingGateway;
|
||||
import org.springframework.integration.gateway.MessagingGatewaySupport;
|
||||
import org.springframework.integration.support.MessageBuilder;
|
||||
import org.springframework.jms.listener.SessionAwareMessageListener;
|
||||
import org.springframework.jms.support.converter.MessageConverter;
|
||||
@@ -46,7 +46,7 @@ import org.springframework.util.Assert;
|
||||
* @author Juergen Hoeller
|
||||
* @author Oleg Zhurakousky
|
||||
*/
|
||||
public class ChannelPublishingJmsMessageListener extends AbstractMessagingGateway
|
||||
public class ChannelPublishingJmsMessageListener extends MessagingGatewaySupport
|
||||
implements SessionAwareMessageListener<javax.jms.Message>, InitializingBean {
|
||||
|
||||
private volatile boolean expectReply;
|
||||
|
||||
@@ -26,7 +26,7 @@ import org.springframework.context.SmartLifecycle;
|
||||
import org.springframework.expression.ExpressionException;
|
||||
import org.springframework.integration.MessageChannel;
|
||||
import org.springframework.integration.MessagingException;
|
||||
import org.springframework.integration.gateway.AbstractMessagingGateway;
|
||||
import org.springframework.integration.gateway.MessagingGatewaySupport;
|
||||
import org.springframework.oxm.Marshaller;
|
||||
import org.springframework.oxm.Unmarshaller;
|
||||
import org.springframework.scheduling.TaskScheduler;
|
||||
@@ -189,7 +189,7 @@ public class MarshallingWebServiceInboundGateway extends AbstractMarshallingPayl
|
||||
return 0;
|
||||
}
|
||||
|
||||
private static class GatewayDelegate extends AbstractMessagingGateway {
|
||||
private static class GatewayDelegate extends MessagingGatewaySupport {
|
||||
|
||||
public Object sendAndReceive(Object request) {
|
||||
return super.sendAndReceive(request);
|
||||
|
||||
@@ -29,7 +29,7 @@ import org.w3c.dom.Document;
|
||||
import org.springframework.expression.ExpressionException;
|
||||
import org.springframework.integration.Message;
|
||||
import org.springframework.integration.MessagingException;
|
||||
import org.springframework.integration.gateway.AbstractMessagingGateway;
|
||||
import org.springframework.integration.gateway.MessagingGatewaySupport;
|
||||
import org.springframework.integration.support.MessageBuilder;
|
||||
import org.springframework.util.Assert;
|
||||
import org.springframework.ws.WebServiceMessage;
|
||||
@@ -45,7 +45,7 @@ import org.springframework.xml.transform.TransformerObjectSupport;
|
||||
* @author Mark Fisher
|
||||
* @since 1.0.2
|
||||
*/
|
||||
public class SimpleWebServiceInboundGateway extends AbstractMessagingGateway implements MessageEndpoint {
|
||||
public class SimpleWebServiceInboundGateway extends MessagingGatewaySupport implements MessageEndpoint {
|
||||
|
||||
private final TransformerSupportDelegate transformerSupportDelegate = new TransformerSupportDelegate();
|
||||
|
||||
|
||||
Reference in New Issue
Block a user