1 package org.codehaus.xfire.transport; 2 3 import org.codehaus.xfire.MessageContext; 4 import org.codehaus.xfire.exchange.InMessage; 5 6 public abstract class AbstractChannel 7 implements Channel 8 { 9 private ChannelEndpoint receiver; 10 private Transport transport; 11 private String uri; 12 13 public String getUri() 14 { 15 return uri; 16 } 17 18 public void setUri(String uri) 19 { 20 this.uri = uri; 21 } 22 23 public void setEndpoint(ChannelEndpoint receiver) 24 { 25 this.receiver = receiver; 26 } 27 28 public ChannelEndpoint getEndpoint() 29 { 30 return receiver; 31 } 32 33 public void receive(MessageContext context, InMessage message) 34 { 35 if (message.getChannel() == null) 36 message.setChannel(this); 37 38 getEndpoint().onReceive(context, message); 39 } 40 41 public Transport getTransport() 42 { 43 return transport; 44 } 45 46 public void setTransport(Transport transport) 47 { 48 this.transport = transport; 49 } 50 }