1 18 package org.apache.activemq.transport.udp; 19 20 import org.apache.activemq.Service; 21 import org.apache.activemq.command.Command; 22 import org.apache.activemq.transport.reliable.ReplayBuffer; 23 import org.apache.activemq.transport.reliable.Replayer; 24 25 import java.io.IOException ; 26 import java.net.SocketAddress ; 27 28 32 public interface CommandChannel extends Replayer, Service { 33 34 public Command read() throws IOException ; 35 36 public void write(Command command, SocketAddress address) throws IOException ; 37 38 public int getDatagramSize(); 39 40 43 public void setDatagramSize(int datagramSize); 44 45 public DatagramHeaderMarshaller getHeaderMarshaller(); 46 47 public void setHeaderMarshaller(DatagramHeaderMarshaller headerMarshaller); 48 49 public void setTargetAddress(SocketAddress address); 50 51 public void setReplayAddress(SocketAddress address); 52 53 public void setReplayBuffer(ReplayBuffer replayBuffer); 54 } 55 | Popular Tags |