1 18 package org.apache.activemq.transport; 19 20 import java.net.InetSocketAddress ; 21 import java.net.URI ; 22 23 import org.apache.activemq.command.BrokerInfo; 24 25 public class TransportServerFilter implements TransportServer { 26 27 protected final TransportServer next; 28 29 32 public TransportServerFilter(TransportServer next) { 33 this.next = next; 34 } 35 36 public URI getConnectURI() { 37 return next.getConnectURI(); 38 } 39 40 public void setAcceptListener(TransportAcceptListener acceptListener) { 41 next.setAcceptListener(acceptListener); 42 } 43 44 public void setBrokerInfo(BrokerInfo brokerInfo) { 45 next.setBrokerInfo(brokerInfo); 46 } 47 48 public void start() throws Exception { 49 next.start(); 50 } 51 52 public void stop() throws Exception { 53 next.stop(); 54 } 55 56 public InetSocketAddress getSocketAddress() { 57 return next.getSocketAddress(); 58 } 59 60 } 61 | Popular Tags |