public class org.apache.activemq.transport.udp.UdpTransportFactory extends org.apache.activemq.transport.TransportFactory
{
private static final org.slf4j.Logger log;
public void <init>()
{
org.apache.activemq.transport.udp.UdpTransportFactory v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
specialinvoke v.<org.apache.activemq.transport.TransportFactory: void <init>()>();
return;
}
public org.apache.activemq.transport.TransportServer doBind(java.net.URI) throws java.io.IOException
{
java.net.URISyntaxException v;
java.util.HashMap v;
java.util.Map v;
int v;
java.net.URI v;
boolean v;
org.apache.activemq.wireformat.WireFormat v;
java.io.IOException v, v;
org.apache.activemq.transport.Transport v, v;
java.lang.IllegalArgumentException v;
java.lang.Exception v;
org.apache.activemq.transport.udp.UdpTransportServer v;
org.apache.activemq.transport.reliable.ReplayStrategy v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: java.net.URI;
label:
v = new java.util.HashMap;
v = staticinvoke <org.apache.activemq.util.URISupport: java.util.Map parseParameters(java.net.URI)>(v);
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>("port");
if v == 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("The port property cannot be specified on a UDP server transport - please use the port in the URI syntax");
throw v;
label:
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.wireformat.WireFormat createWireFormat(java.util.Map)>(v);
virtualinvoke v.<java.net.URI: int getPort()>();
virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.openwire.OpenWireFormat asOpenWireFormat(org.apache.activemq.wireformat.WireFormat)>(v);
v = virtualinvoke v.<java.net.URI: int getPort()>();
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.Transport createTransport(int,org.apache.activemq.wireformat.WireFormat)>(v, v);
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.Transport configure(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat,java.util.Map,boolean)>(v, v, v, 1);
v = new org.apache.activemq.transport.udp.UdpTransportServer;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.reliable.ReplayStrategy createReplayStrategy()>();
specialinvoke v.<org.apache.activemq.transport.udp.UdpTransportServer: void <init>(java.net.URI,org.apache.activemq.transport.udp.UdpTransport,org.apache.activemq.transport.Transport,org.apache.activemq.transport.reliable.ReplayStrategy)>(v, v, v, v);
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Exception)>(v);
throw v;
label:
v := @caughtexception;
v = staticinvoke <org.apache.activemq.util.IOExceptionSupport: java.io.IOException create(java.lang.Exception)>(v);
throw v;
catch java.net.URISyntaxException from label to label with label;
catch java.lang.Exception from label to label with label;
}
public org.apache.activemq.transport.Transport configure(org.apache.activemq.transport.Transport, org.apache.activemq.wireformat.WireFormat, java.util.Map) throws java.lang.Exception
{
org.apache.activemq.transport.udp.UdpTransportFactory v;
java.util.Map v;
org.apache.activemq.wireformat.WireFormat v;
org.apache.activemq.transport.Transport v, v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: org.apache.activemq.transport.Transport;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v := @parameter: java.util.Map;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.Transport configure(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat,java.util.Map,boolean)>(v, v, v, 0);
return v;
}
public org.apache.activemq.transport.Transport compositeConfigure(org.apache.activemq.transport.Transport, org.apache.activemq.wireformat.WireFormat, java.util.Map)
{
java.lang.Throwable v;
org.slf4j.Logger v;
org.apache.activemq.wireformat.WireFormat v;
org.apache.activemq.transport.Transport v, v, v;
org.apache.activemq.transport.CommandJoiner v;
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
java.util.Map v;
org.apache.activemq.transport.InactivityMonitor v;
java.lang.String v;
boolean v, v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: org.apache.activemq.transport.Transport;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v := @parameter: java.util.Map;
staticinvoke <org.apache.activemq.util.IntrospectionSupport: boolean setProperties(java.lang.Object,java.util.Map)>(v, v);
v = new org.apache.activemq.transport.CommandJoiner;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.openwire.OpenWireFormat asOpenWireFormat(org.apache.activemq.wireformat.WireFormat)>(v);
specialinvoke v.<org.apache.activemq.transport.CommandJoiner: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.openwire.OpenWireFormat)>(v, v);
v = v;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransport: boolean isTrace()>();
if v == 0 goto label;
label:
v = staticinvoke <org.apache.activemq.TransportLoggerSupport: org.apache.activemq.transport.Transport createTransportLogger(org.apache.activemq.transport.Transport)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.transport.udp.UdpTransportFactory: org.slf4j.Logger log>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Throwable)>(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[])>("Could not create TransportLogger, reason: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>(v, v);
label:
v = new org.apache.activemq.transport.InactivityMonitor;
specialinvoke v.<org.apache.activemq.transport.InactivityMonitor: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat)>(v, v);
v = v;
v = v instanceof org.apache.activemq.openwire.OpenWireFormat;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.Transport configureClientSideNegotiator(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat,org.apache.activemq.transport.udp.UdpTransport)>(v, v, v);
label:
return v;
catch java.lang.Throwable from label to label with label;
}
protected org.apache.activemq.transport.Transport createTransport(java.net.URI, org.apache.activemq.wireformat.WireFormat) throws java.net.UnknownHostException, java.io.IOException
{
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
org.apache.activemq.wireformat.WireFormat v;
java.net.URI v;
org.apache.activemq.transport.udp.UdpTransport v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: java.net.URI;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.openwire.OpenWireFormat asOpenWireFormat(org.apache.activemq.wireformat.WireFormat)>(v);
v = new org.apache.activemq.transport.udp.UdpTransport;
specialinvoke v.<org.apache.activemq.transport.udp.UdpTransport: void <init>(org.apache.activemq.openwire.OpenWireFormat,java.net.URI)>(v, v);
return v;
}
protected org.apache.activemq.transport.Transport createTransport(int, org.apache.activemq.wireformat.WireFormat) throws java.net.UnknownHostException, java.io.IOException
{
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
org.apache.activemq.wireformat.WireFormat v;
int v;
org.apache.activemq.transport.udp.UdpTransport v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: int;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.openwire.OpenWireFormat asOpenWireFormat(org.apache.activemq.wireformat.WireFormat)>(v);
v = new org.apache.activemq.transport.udp.UdpTransport;
specialinvoke v.<org.apache.activemq.transport.udp.UdpTransport: void <init>(org.apache.activemq.openwire.OpenWireFormat,int)>(v, v);
return v;
}
protected org.apache.activemq.transport.Transport configure(org.apache.activemq.transport.Transport, org.apache.activemq.wireformat.WireFormat, java.util.Map, boolean) throws java.lang.Exception
{
org.apache.activemq.transport.reliable.ReliableTransport v;
org.apache.activemq.wireformat.WireFormat v;
org.apache.activemq.transport.Transport v, v;
org.apache.activemq.transport.reliable.Replayer v;
org.apache.activemq.transport.CommandJoiner v, v;
org.apache.activemq.openwire.OpenWireFormat v;
org.apache.activemq.transport.reliable.ReplayStrategy v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
java.util.Map v;
org.apache.activemq.transport.InactivityMonitor v;
boolean v, v, v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: org.apache.activemq.transport.Transport;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v := @parameter: java.util.Map;
v := @parameter: boolean;
staticinvoke <org.apache.activemq.util.IntrospectionSupport: boolean setProperties(java.lang.Object,java.util.Map)>(v, v);
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.openwire.OpenWireFormat asOpenWireFormat(org.apache.activemq.wireformat.WireFormat)>(v);
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransport: boolean isTrace()>();
if v == 0 goto label;
v = staticinvoke <org.apache.activemq.TransportLoggerSupport: org.apache.activemq.transport.Transport createTransportLogger(org.apache.activemq.transport.Transport)>(v);
label:
v = new org.apache.activemq.transport.InactivityMonitor;
specialinvoke v.<org.apache.activemq.transport.InactivityMonitor: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat)>(v, v);
v = v;
if v != 0 goto label;
v = v instanceof org.apache.activemq.openwire.OpenWireFormat;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.Transport configureClientSideNegotiator(org.apache.activemq.transport.Transport,org.apache.activemq.wireformat.WireFormat,org.apache.activemq.transport.udp.UdpTransport)>(v, v, v);
label:
if v == 0 goto label;
virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransport: void setReplayEnabled(boolean)>(0);
v = new org.apache.activemq.transport.CommandJoiner;
specialinvoke v.<org.apache.activemq.transport.CommandJoiner: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.openwire.OpenWireFormat)>(v, v);
return v;
label:
v = new org.apache.activemq.transport.reliable.ReliableTransport;
specialinvoke v.<org.apache.activemq.transport.reliable.ReliableTransport: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.transport.udp.UdpTransport)>(v, v);
v = virtualinvoke v.<org.apache.activemq.transport.reliable.ReliableTransport: org.apache.activemq.transport.reliable.Replayer getReplayer()>();
v = virtualinvoke v.<org.apache.activemq.transport.udp.UdpTransportFactory: org.apache.activemq.transport.reliable.ReplayStrategy createReplayStrategy(org.apache.activemq.transport.reliable.Replayer)>(v);
virtualinvoke v.<org.apache.activemq.transport.reliable.ReliableTransport: void setReplayStrategy(org.apache.activemq.transport.reliable.ReplayStrategy)>(v);
v = new org.apache.activemq.transport.CommandJoiner;
specialinvoke v.<org.apache.activemq.transport.CommandJoiner: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.openwire.OpenWireFormat)>(v, v);
return v;
}
protected org.apache.activemq.transport.reliable.ReplayStrategy createReplayStrategy(org.apache.activemq.transport.reliable.Replayer)
{
org.apache.activemq.transport.reliable.Replayer v;
org.apache.activemq.transport.reliable.DefaultReplayStrategy v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
org.apache.activemq.transport.reliable.ExceptionIfDroppedReplayStrategy v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: org.apache.activemq.transport.reliable.Replayer;
if v == null goto label;
v = new org.apache.activemq.transport.reliable.DefaultReplayStrategy;
specialinvoke v.<org.apache.activemq.transport.reliable.DefaultReplayStrategy: void <init>(int)>(5);
return v;
label:
v = new org.apache.activemq.transport.reliable.ExceptionIfDroppedReplayStrategy;
specialinvoke v.<org.apache.activemq.transport.reliable.ExceptionIfDroppedReplayStrategy: void <init>(int)>(1);
return v;
}
protected org.apache.activemq.transport.reliable.ReplayStrategy createReplayStrategy()
{
org.apache.activemq.transport.reliable.DefaultReplayStrategy v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v = new org.apache.activemq.transport.reliable.DefaultReplayStrategy;
specialinvoke v.<org.apache.activemq.transport.reliable.DefaultReplayStrategy: void <init>(int)>(5);
return v;
}
protected org.apache.activemq.transport.Transport configureClientSideNegotiator(org.apache.activemq.transport.Transport, org.apache.activemq.wireformat.WireFormat, org.apache.activemq.transport.udp.UdpTransport)
{
org.apache.activemq.transport.udp.ResponseRedirectInterceptor v;
org.apache.activemq.transport.udp.UdpTransportFactory v;
org.apache.activemq.wireformat.WireFormat v;
org.apache.activemq.transport.Transport v;
org.apache.activemq.transport.udp.UdpTransport v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: org.apache.activemq.transport.Transport;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
v := @parameter: org.apache.activemq.transport.udp.UdpTransport;
v = new org.apache.activemq.transport.udp.ResponseRedirectInterceptor;
specialinvoke v.<org.apache.activemq.transport.udp.ResponseRedirectInterceptor: void <init>(org.apache.activemq.transport.Transport,org.apache.activemq.transport.udp.UdpTransport)>(v, v);
return v;
}
protected org.apache.activemq.openwire.OpenWireFormat asOpenWireFormat(org.apache.activemq.wireformat.WireFormat)
{
org.apache.activemq.transport.udp.UdpTransportFactory v;
org.apache.activemq.wireformat.WireFormat v;
v := @this: org.apache.activemq.transport.udp.UdpTransportFactory;
v := @parameter: org.apache.activemq.wireformat.WireFormat;
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/transport/tcp/TcpTransportFactory;");
<org.apache.activemq.transport.udp.UdpTransportFactory: org.slf4j.Logger log> = v;
return;
}
}