public abstract class org.apache.activemq.transport.udp.CommandChannelSupport extends java.lang.Object implements org.apache.activemq.transport.udp.CommandChannel
{
protected org.apache.activemq.openwire.OpenWireFormat wireFormat;
protected int datagramSize;
protected java.net.SocketAddress targetAddress;
protected java.net.SocketAddress replayAddress;
protected final java.lang.String name;
protected final org.apache.activemq.util.IntSequenceGenerator sequenceGenerator;
protected org.apache.activemq.transport.udp.DatagramHeaderMarshaller headerMarshaller;
private org.apache.activemq.transport.reliable.ReplayBuffer replayBuffer;
public void <init>(org.apache.activemq.transport.udp.UdpTransport, org.apache.activemq.openwire.OpenWireFormat, int, java.net.SocketAddress, org.apache.activemq.transport.udp.DatagramHeaderMarshaller)
{
java.net.SocketAddress v;
org.apache.activemq.transport.udp.DatagramHeaderMarshaller v;
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.lang.IllegalArgumentException v;
org.apache.activemq.openwire.OpenWireFormat v;
int v;
org.apache.activemq.util.IntSequenceGenerator v, v;
java.lang.String v, v;
org.apache.activemq.transport.udp.UdpTransport v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: org.apache.activemq.transport.udp.UdpTransport;
v := @parameter: org.apache.activemq.openwire.OpenWireFormat;
v := @parameter: int;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.apache.activemq.transport.udp.DatagramHeaderMarshaller;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.activemq.transport.udp.CommandChannelSupport: int datagramSize> = 4096;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.openwire.OpenWireFormat wireFormat> = v;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: int datagramSize> = v;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress targetAddress> = v;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.transport.udp.DatagramHeaderMarshaller headerMarshaller> = v;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransport: java.lang.String toString()>();
v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.lang.String name> = v;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransport: org.apache.activemq.util.IntSequenceGenerator getSequenceGenerator()>();
v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.util.IntSequenceGenerator sequenceGenerator> = v;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress replayAddress> = v;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.util.IntSequenceGenerator sequenceGenerator>;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.transport.udp.UdpTransport)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("No sequenceGenerator on the given transport: \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void write(org.apache.activemq.command.Command) throws java.io.IOException
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.net.SocketAddress v;
org.apache.activemq.command.Command v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: org.apache.activemq.command.Command;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress targetAddress>;
virtualinvoke v.<org.apache.activemq.transport.udp.CommandChannelSupport: void write(org.apache.activemq.command.Command,java.net.SocketAddress)>(v, v);
return;
}
public int getDatagramSize()
{
int v;
org.apache.activemq.transport.udp.CommandChannelSupport v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: int datagramSize>;
return v;
}
public void setDatagramSize(int)
{
int v;
org.apache.activemq.transport.udp.CommandChannelSupport v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: int;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: int datagramSize> = v;
return;
}
public java.net.SocketAddress getTargetAddress()
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.net.SocketAddress v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress targetAddress>;
return v;
}
public void setTargetAddress(java.net.SocketAddress)
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.net.SocketAddress v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: java.net.SocketAddress;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress targetAddress> = v;
return;
}
public java.net.SocketAddress getReplayAddress()
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.net.SocketAddress v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress replayAddress>;
return v;
}
public void setReplayAddress(java.net.SocketAddress)
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.net.SocketAddress v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: java.net.SocketAddress;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.net.SocketAddress replayAddress> = v;
return;
}
public java.lang.String toString()
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
java.lang.String v, v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: java.lang.String name>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("CommandChannel#\u0001");
return v;
}
public org.apache.activemq.transport.udp.DatagramHeaderMarshaller getHeaderMarshaller()
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
org.apache.activemq.transport.udp.DatagramHeaderMarshaller v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.transport.udp.DatagramHeaderMarshaller headerMarshaller>;
return v;
}
public void setHeaderMarshaller(org.apache.activemq.transport.udp.DatagramHeaderMarshaller)
{
org.apache.activemq.transport.udp.CommandChannelSupport v;
org.apache.activemq.transport.udp.DatagramHeaderMarshaller v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: org.apache.activemq.transport.udp.DatagramHeaderMarshaller;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.transport.udp.DatagramHeaderMarshaller headerMarshaller> = v;
return;
}
public org.apache.activemq.transport.reliable.ReplayBuffer getReplayBuffer()
{
org.apache.activemq.transport.reliable.ReplayBuffer v;
org.apache.activemq.transport.udp.CommandChannelSupport v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v = v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.transport.reliable.ReplayBuffer replayBuffer>;
return v;
}
public void setReplayBuffer(org.apache.activemq.transport.reliable.ReplayBuffer)
{
org.apache.activemq.transport.reliable.ReplayBuffer v;
org.apache.activemq.transport.udp.CommandChannelSupport v;
v := @this: org.apache.activemq.transport.udp.CommandChannelSupport;
v := @parameter: org.apache.activemq.transport.reliable.ReplayBuffer;
v.<org.apache.activemq.transport.udp.CommandChannelSupport: org.apache.activemq.transport.reliable.ReplayBuffer replayBuffer> = v;
return;
}
}