public class org.apache.activemq.broker.util.UDPTraceBrokerPlugin extends org.apache.activemq.broker.BrokerPluginSupport
{
private static final org.slf4j.Logger LOG;
protected org.apache.activemq.wireformat.WireFormat wireFormat;
protected org.apache.activemq.wireformat.WireFormatFactory wireFormatFactory;
protected int maxTraceDatagramSize;
protected java.net.URI destination;
protected java.net.DatagramSocket socket;
protected org.apache.activemq.command.BrokerId brokerId;
protected java.net.SocketAddress address;
protected boolean broadcast;
public void <init>()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
java.net.URI v;
java.net.URISyntaxException v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void <init>()>();
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: int maxTraceDatagramSize> = 4096;
label:
v = new java.net.URI;
specialinvoke v.<java.net.URI: void <init>(java.lang.String)>("udp://127.0.0.1:61616");
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.URI destination> = v;
label:
goto label;
label:
v := @caughtexception;
label:
return;
catch java.net.URISyntaxException from label to label with label;
}
public void start() throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
java.net.SocketAddress v, v;
org.apache.activemq.wireformat.WireFormat v;
java.lang.IllegalArgumentException v;
java.net.DatagramSocket v;
org.apache.activemq.command.JournalTrace v;
org.apache.activemq.command.BrokerId v;
java.net.URI v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void start()>();
v = virtualinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat getWireFormat()>();
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Wireformat must be specifed.");
throw v;
label:
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.SocketAddress address>;
if v != null goto label;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.URI destination>;
v = virtualinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.SocketAddress createSocketAddress(java.net.URI)>(v);
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.SocketAddress address> = v;
label:
v = virtualinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.DatagramSocket createSocket()>();
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.DatagramSocket socket> = v;
v = specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: org.apache.activemq.command.BrokerId getBrokerId()>();
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.command.BrokerId brokerId> = v;
v = new org.apache.activemq.command.JournalTrace;
specialinvoke v.<org.apache.activemq.command.JournalTrace: void <init>(java.lang.String)>("START");
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
return;
}
protected java.net.DatagramSocket createSocket() throws java.io.IOException
{
java.net.DatagramSocket v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
int v;
boolean v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = new java.net.DatagramSocket;
specialinvoke v.<java.net.DatagramSocket: void <init>()>();
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: int maxTraceDatagramSize>;
virtualinvoke v.<java.net.DatagramSocket: void setSendBufferSize(int)>(v);
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: boolean broadcast>;
virtualinvoke v.<java.net.DatagramSocket: void setBroadcast(boolean)>(v);
return v;
}
public void stop() throws java.lang.Exception
{
java.net.DatagramSocket v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.command.JournalTrace v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = new org.apache.activemq.command.JournalTrace;
specialinvoke v.<org.apache.activemq.command.JournalTrace: void <init>(java.lang.String)>("STOP");
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.DatagramSocket socket>;
virtualinvoke v.<java.net.DatagramSocket: void close()>();
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void stop()>();
return;
}
private void trace(org.apache.activemq.command.DataStructure)
{
java.lang.Throwable v;
org.apache.activemq.util.ByteArrayOutputStream v;
byte[] v;
java.net.SocketAddress v;
java.net.DatagramSocket v;
java.io.DataOutputStream v;
int v, v, v;
org.apache.activemq.util.ByteSequence v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.slf4j.Logger v;
org.apache.activemq.wireformat.WireFormat v, v;
org.apache.activemq.command.BrokerId v;
org.apache.activemq.command.DataStructure v;
java.net.DatagramPacket v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.command.DataStructure;
label:
v = new org.apache.activemq.util.ByteArrayOutputStream;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: int maxTraceDatagramSize>;
specialinvoke v.<org.apache.activemq.util.ByteArrayOutputStream: void <init>(int)>(v);
v = new java.io.DataOutputStream;
specialinvoke v.<java.io.DataOutputStream: void <init>(java.io.OutputStream)>(v);
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat wireFormat>;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.command.BrokerId brokerId>;
interfaceinvoke v.<org.apache.activemq.wireformat.WireFormat: void marshal(java.lang.Object,java.io.DataOutput)>(v, v);
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat wireFormat>;
interfaceinvoke v.<org.apache.activemq.wireformat.WireFormat: void marshal(java.lang.Object,java.io.DataOutput)>(v, v);
virtualinvoke v.<java.io.DataOutputStream: void close()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteArrayOutputStream: org.apache.activemq.util.ByteSequence toByteSequence()>();
v = new java.net.DatagramPacket;
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: byte[] getData()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: int getOffset()>();
v = virtualinvoke v.<org.apache.activemq.util.ByteSequence: int getLength()>();
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.SocketAddress address>;
specialinvoke v.<java.net.DatagramPacket: void <init>(byte[],int,int,java.net.SocketAddress)>(v, v, v, v);
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.DatagramSocket socket>;
virtualinvoke v.<java.net.DatagramSocket: void send(java.net.DatagramPacket)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Failed to trace: {}", v, v);
label:
return;
catch java.lang.Throwable from label to label with label;
}
public void send(org.apache.activemq.broker.ProducerBrokerExchange, org.apache.activemq.command.Message) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.command.Message v;
org.apache.activemq.broker.ProducerBrokerExchange v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ProducerBrokerExchange;
v := @parameter: org.apache.activemq.command.Message;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void send(org.apache.activemq.broker.ProducerBrokerExchange,org.apache.activemq.command.Message)>(v, v);
return;
}
public void acknowledge(org.apache.activemq.broker.ConsumerBrokerExchange, org.apache.activemq.command.MessageAck) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConsumerBrokerExchange v;
org.apache.activemq.command.MessageAck v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConsumerBrokerExchange;
v := @parameter: org.apache.activemq.command.MessageAck;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void acknowledge(org.apache.activemq.broker.ConsumerBrokerExchange,org.apache.activemq.command.MessageAck)>(v, v);
return;
}
public void addConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.ConnectionInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ConnectionInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void addConnection(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConnectionInfo)>(v, v);
return;
}
public org.apache.activemq.broker.region.Subscription addConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.broker.region.Subscription v;
org.apache.activemq.command.ConsumerInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ConsumerInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
v = specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: org.apache.activemq.broker.region.Subscription addConsumer(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v);
return v;
}
public void addDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.DestinationInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.DestinationInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void addDestinationInfo(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.DestinationInfo)>(v, v);
return;
}
public void addProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.ProducerInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ProducerInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void addProducer(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ProducerInfo)>(v, v);
return;
}
public void addSession(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.SessionInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.SessionInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.SessionInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void addSession(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.SessionInfo)>(v, v);
return;
}
public void beginTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.TransactionInfo v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.TransactionId;
v = new org.apache.activemq.command.TransactionInfo;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.command.ConnectionId getConnectionId()>();
specialinvoke v.<org.apache.activemq.command.TransactionInfo: void <init>(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 0);
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void beginTransaction(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.TransactionId)>(v, v);
return;
}
public void commitTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId, boolean) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.TransactionInfo v;
byte v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.TransactionId v;
boolean v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.TransactionId;
v := @parameter: boolean;
v = new org.apache.activemq.command.TransactionInfo;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.command.ConnectionId getConnectionId()>();
if v == 0 goto label;
v = 2;
goto label;
label:
v = 3;
label:
specialinvoke v.<org.apache.activemq.command.TransactionInfo: void <init>(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, v);
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void commitTransaction(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.TransactionId,boolean)>(v, v, v);
return;
}
public void forgetTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.TransactionInfo v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.TransactionId;
v = new org.apache.activemq.command.TransactionInfo;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.command.ConnectionId getConnectionId()>();
specialinvoke v.<org.apache.activemq.command.TransactionInfo: void <init>(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 6);
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void forgetTransaction(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.TransactionId)>(v, v);
return;
}
public org.apache.activemq.command.Response messagePull(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.MessagePull) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.command.Response v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.MessagePull v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.MessagePull;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
v = specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: org.apache.activemq.command.Response messagePull(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.MessagePull)>(v, v);
return v;
}
public int prepareTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.TransactionInfo v;
org.apache.activemq.command.ConnectionId v;
int v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.TransactionId;
v = new org.apache.activemq.command.TransactionInfo;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.command.ConnectionId getConnectionId()>();
specialinvoke v.<org.apache.activemq.command.TransactionInfo: void <init>(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 1);
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
v = specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: int prepareTransaction(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.TransactionId)>(v, v);
return v;
}
public void postProcessDispatch(org.apache.activemq.command.MessageDispatch)
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.command.MessageDispatch v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.command.MessageDispatch;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void postProcessDispatch(org.apache.activemq.command.MessageDispatch)>(v);
return;
}
public void processDispatchNotification(org.apache.activemq.command.MessageDispatchNotification) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.command.MessageDispatchNotification v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.command.MessageDispatchNotification;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void processDispatchNotification(org.apache.activemq.command.MessageDispatchNotification)>(v);
return;
}
public void removeConnection(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConnectionInfo, java.lang.Throwable) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.ConnectionInfo v;
org.apache.activemq.command.RemoveInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ConnectionInfo;
v := @parameter: java.lang.Throwable;
v = virtualinvoke v.<org.apache.activemq.command.ConnectionInfo: org.apache.activemq.command.RemoveInfo createRemoveCommand()>();
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeConnection(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConnectionInfo,java.lang.Throwable)>(v, v, v);
return;
}
public void removeConsumer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ConsumerInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.ConsumerInfo v;
org.apache.activemq.command.RemoveInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ConsumerInfo;
v = virtualinvoke v.<org.apache.activemq.command.ConsumerInfo: org.apache.activemq.command.RemoveInfo createRemoveCommand()>();
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeConsumer(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ConsumerInfo)>(v, v);
return;
}
public void removeDestination(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ActiveMQDestination, long) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
long v;
org.apache.activemq.command.ActiveMQDestination v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ActiveMQDestination;
v := @parameter: long;
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeDestination(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ActiveMQDestination,long)>(v, v, v);
return;
}
public void removeDestinationInfo(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.DestinationInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.DestinationInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.DestinationInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeDestinationInfo(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.DestinationInfo)>(v, v);
return;
}
public void removeProducer(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.ProducerInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.ProducerInfo v;
org.apache.activemq.command.RemoveInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.ProducerInfo;
v = virtualinvoke v.<org.apache.activemq.command.ProducerInfo: org.apache.activemq.command.RemoveInfo createRemoveCommand()>();
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeProducer(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.ProducerInfo)>(v, v);
return;
}
public void removeSession(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.SessionInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.SessionInfo v;
org.apache.activemq.command.RemoveInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.SessionInfo;
v = virtualinvoke v.<org.apache.activemq.command.SessionInfo: org.apache.activemq.command.RemoveInfo createRemoveCommand()>();
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeSession(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.SessionInfo)>(v, v);
return;
}
public void removeSubscription(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.RemoveSubscriptionInfo) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.RemoveSubscriptionInfo v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.RemoveSubscriptionInfo;
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void removeSubscription(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.RemoveSubscriptionInfo)>(v, v);
return;
}
public void rollbackTransaction(org.apache.activemq.broker.ConnectionContext, org.apache.activemq.command.TransactionId) throws java.lang.Exception
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.broker.ConnectionContext v;
org.apache.activemq.command.TransactionInfo v;
org.apache.activemq.command.ConnectionId v;
org.apache.activemq.command.TransactionId v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.broker.ConnectionContext;
v := @parameter: org.apache.activemq.command.TransactionId;
v = new org.apache.activemq.command.TransactionInfo;
v = virtualinvoke v.<org.apache.activemq.broker.ConnectionContext: org.apache.activemq.command.ConnectionId getConnectionId()>();
specialinvoke v.<org.apache.activemq.command.TransactionInfo: void <init>(org.apache.activemq.command.ConnectionId,org.apache.activemq.command.TransactionId,byte)>(v, v, 4);
specialinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: void trace(org.apache.activemq.command.DataStructure)>(v);
specialinvoke v.<org.apache.activemq.broker.BrokerPluginSupport: void rollbackTransaction(org.apache.activemq.broker.ConnectionContext,org.apache.activemq.command.TransactionId)>(v, v);
return;
}
public org.apache.activemq.wireformat.WireFormat getWireFormat()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.wireformat.WireFormat v, v, v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat wireFormat>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat createWireFormat()>();
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat wireFormat> = v;
label:
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat wireFormat>;
return v;
}
protected org.apache.activemq.wireformat.WireFormat createWireFormat()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.wireformat.WireFormatFactory v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = virtualinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormatFactory getWireFormatFactory()>();
v = interfaceinvoke v.<org.apache.activemq.wireformat.WireFormatFactory: org.apache.activemq.wireformat.WireFormat createWireFormat()>();
return v;
}
public void setWireFormat(org.apache.activemq.wireformat.WireFormat)
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormat wireFormat> = v;
return;
}
public org.apache.activemq.wireformat.WireFormatFactory getWireFormatFactory()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.openwire.OpenWireFormatFactory v;
org.apache.activemq.wireformat.WireFormatFactory v, v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormatFactory wireFormatFactory>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.openwire.OpenWireFormatFactory createWireFormatFactory()>();
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormatFactory wireFormatFactory> = v;
label:
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormatFactory wireFormatFactory>;
return v;
}
protected org.apache.activemq.openwire.OpenWireFormatFactory createWireFormatFactory()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.openwire.OpenWireFormatFactory v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = new org.apache.activemq.openwire.OpenWireFormatFactory;
specialinvoke v.<org.apache.activemq.openwire.OpenWireFormatFactory: void <init>()>();
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormatFactory: void setCacheEnabled(boolean)>(0);
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormatFactory: void setVersion(int)>(1);
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormatFactory: void setTightEncodingEnabled(boolean)>(1);
virtualinvoke v.<org.apache.activemq.openwire.OpenWireFormatFactory: void setSizePrefixDisabled(boolean)>(1);
return v;
}
public void setWireFormatFactory(org.apache.activemq.wireformat.WireFormatFactory)
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
org.apache.activemq.wireformat.WireFormatFactory v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: org.apache.activemq.wireformat.WireFormatFactory;
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.apache.activemq.wireformat.WireFormatFactory wireFormatFactory> = v;
return;
}
protected java.net.SocketAddress createSocketAddress(java.net.URI) throws java.net.UnknownHostException
{
java.net.InetAddress v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
int v;
java.lang.String v;
java.net.URI v;
java.net.InetSocketAddress v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: java.net.URI;
v = virtualinvoke v.<java.net.URI: java.lang.String getHost()>();
v = staticinvoke <java.net.InetAddress: java.net.InetAddress getByName(java.lang.String)>(v);
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = new java.net.InetSocketAddress;
specialinvoke v.<java.net.InetSocketAddress: void <init>(java.net.InetAddress,int)>(v, v);
return v;
}
public java.net.URI getDestination()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
java.net.URI v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.URI destination>;
return v;
}
public void setDestination(java.net.URI)
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
java.net.URI v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: java.net.URI;
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.URI destination> = v;
return;
}
public int getMaxTraceDatagramSize()
{
int v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: int maxTraceDatagramSize>;
return v;
}
public void setMaxTraceDatagramSize(int)
{
int v;
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: int;
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: int maxTraceDatagramSize> = v;
return;
}
public boolean isBroadcast()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
boolean v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: boolean broadcast>;
return v;
}
public void setBroadcast(boolean)
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
boolean v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: boolean;
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: boolean broadcast> = v;
return;
}
public java.net.SocketAddress getAddress()
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
java.net.SocketAddress v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v = v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.SocketAddress address>;
return v;
}
public void setAddress(java.net.SocketAddress)
{
org.apache.activemq.broker.util.UDPTraceBrokerPlugin v;
java.net.SocketAddress v;
v := @this: org.apache.activemq.broker.util.UDPTraceBrokerPlugin;
v := @parameter: java.net.SocketAddress;
v.<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: java.net.SocketAddress address> = v;
return;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/broker/util/UDPTraceBrokerPlugin;");
<org.apache.activemq.broker.util.UDPTraceBrokerPlugin: org.slf4j.Logger LOG> = v;
return;
}
}