diff --git a/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/AMQPTransportEndpoint.java b/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/AMQPTransportEndpoint.java index 9616eb892..e79094bc1 100644 --- a/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/AMQPTransportEndpoint.java +++ b/modules/transports/optional/amqp/src/main/java/org/apache/synapse/transport/amqp/AMQPTransportEndpoint.java @@ -31,8 +31,6 @@ */ public class AMQPTransportEndpoint extends ProtocolEndpoint { - private Set endpointReferences = new HashSet(); - private ScheduledExecutorService workerPool; private AMQPTransportPollingTask pollingTask; @@ -88,6 +86,6 @@ public boolean loadConfiguration(ParameterInclude params) throws AxisFault { @Override public EndpointReference[] getEndpointReferences(AxisService service, String ip) throws AxisFault { - return endpointReferences.toArray(new EndpointReference[endpointReferences.size()]); + return new EndpointReference[0]; } } \ No newline at end of file