public class org.apache.activemq.network.MulticastNetworkConnector extends org.apache.activemq.network.NetworkConnector
{
private org.apache.activemq.transport.Transport localTransport;
private org.apache.activemq.transport.Transport remoteTransport;
private java.net.URI remoteURI;
private org.apache.activemq.network.DemandForwardingBridgeSupport bridge;
public void <init>()
{
org.apache.activemq.network.MulticastNetworkConnector v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
specialinvoke v.<org.apache.activemq.network.NetworkConnector: void <init>()>();
return;
}
public void <init>(java.net.URI)
{
org.apache.activemq.network.MulticastNetworkConnector v;
java.net.URI v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: java.net.URI;
specialinvoke v.<org.apache.activemq.network.NetworkConnector: void <init>()>();
v.<org.apache.activemq.network.MulticastNetworkConnector: java.net.URI remoteURI> = v;
return;
}
public org.apache.activemq.network.DemandForwardingBridgeSupport getBridge()
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.network.DemandForwardingBridgeSupport v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge>;
return v;
}
public void setBridge(org.apache.activemq.network.DemandForwardingBridgeSupport)
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.network.DemandForwardingBridgeSupport v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: org.apache.activemq.network.DemandForwardingBridgeSupport;
v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge> = v;
return;
}
public org.apache.activemq.transport.Transport getLocalTransport()
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport>;
return v;
}
public void setLocalTransport(org.apache.activemq.transport.Transport)
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: org.apache.activemq.transport.Transport;
v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport> = v;
return;
}
public org.apache.activemq.transport.Transport getRemoteTransport()
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
return v;
}
public void setRemoteTransport(org.apache.activemq.transport.Transport)
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: org.apache.activemq.transport.Transport;
v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport> = v;
return;
}
public java.net.URI getRemoteURI()
{
org.apache.activemq.network.MulticastNetworkConnector v;
java.net.URI v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: java.net.URI remoteURI>;
return v;
}
public void setRemoteURI(java.net.URI)
{
org.apache.activemq.network.MulticastNetworkConnector v;
java.net.URI v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: java.net.URI;
v.<org.apache.activemq.network.MulticastNetworkConnector: java.net.URI remoteURI> = v;
return;
}
protected void handleStart() throws java.lang.Exception
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v, v, v, v, v, v, v, v;
org.apache.activemq.network.DemandForwardingBridgeSupport v, v, v;
java.lang.IllegalArgumentException v;
java.net.URI v, v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
if v != null goto label;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: java.net.URI remoteURI>;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("You must specify the remoteURI property");
throw v;
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: java.net.URI remoteURI>;
v = staticinvoke <org.apache.activemq.transport.TransportFactory: org.apache.activemq.transport.Transport connect(java.net.URI)>(v);
v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport> = v;
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport>;
if v != null goto label;
v = virtualinvoke v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport createLocalTransport()>();
v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport> = v;
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport>;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
v = virtualinvoke v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport createBridge(org.apache.activemq.transport.Transport,org.apache.activemq.transport.Transport)>(v, v);
v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge> = v;
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge>;
virtualinvoke v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.NetworkBridge configureBridge(org.apache.activemq.network.DemandForwardingBridgeSupport)>(v);
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge>;
virtualinvoke v.<org.apache.activemq.network.DemandForwardingBridgeSupport: void start()>();
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
interfaceinvoke v.<org.apache.activemq.transport.Transport: void start()>();
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport>;
interfaceinvoke v.<org.apache.activemq.transport.Transport: void start()>();
specialinvoke v.<org.apache.activemq.network.NetworkConnector: void handleStart()>();
return;
}
protected void handleStop(org.apache.activemq.util.ServiceStopper) throws java.lang.Exception
{
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v, v, v, v;
org.apache.activemq.network.DemandForwardingBridgeSupport v, v;
java.lang.Exception v, v, v;
org.apache.activemq.util.ServiceStopper v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: org.apache.activemq.util.ServiceStopper;
specialinvoke v.<org.apache.activemq.network.NetworkConnector: void handleStop(org.apache.activemq.util.ServiceStopper)>(v);
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge>;
if v == null goto label;
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.network.DemandForwardingBridgeSupport bridge>;
virtualinvoke v.<org.apache.activemq.network.DemandForwardingBridgeSupport: void stop()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void onException(java.lang.Object,java.lang.Throwable)>(v, v);
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
if v == null goto label;
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
interfaceinvoke v.<org.apache.activemq.transport.Transport: void stop()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void onException(java.lang.Object,java.lang.Throwable)>(v, v);
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport>;
if v == null goto label;
label:
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport localTransport>;
interfaceinvoke v.<org.apache.activemq.transport.Transport: void stop()>();
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<org.apache.activemq.util.ServiceStopper: void onException(java.lang.Object,java.lang.Throwable)>(v, v);
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
public java.lang.String toString()
{
org.apache.activemq.network.MulticastNetworkConnector v;
java.lang.Class v;
org.apache.activemq.transport.Transport v;
java.lang.String v, v, v, v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = virtualinvoke v.<org.apache.activemq.network.MulticastNetworkConnector: java.lang.String getName()>();
v = v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.transport.Transport remoteTransport>;
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,java.lang.String)>(v, v, 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[])>("\u0001:\u[\u]");
return v;
}
protected org.apache.activemq.network.DemandForwardingBridgeSupport createBridge(org.apache.activemq.transport.Transport, org.apache.activemq.transport.Transport)
{
org.apache.activemq.broker.BrokerService v;
org.apache.activemq.network.MulticastNetworkConnector v;
org.apache.activemq.transport.Transport v, v;
org.apache.activemq.network.CompositeDemandForwardingBridge v;
v := @this: org.apache.activemq.network.MulticastNetworkConnector;
v := @parameter: org.apache.activemq.transport.Transport;
v := @parameter: org.apache.activemq.transport.Transport;
v = new org.apache.activemq.network.CompositeDemandForwardingBridge;
specialinvoke v.<org.apache.activemq.network.CompositeDemandForwardingBridge: void <init>(org.apache.activemq.network.NetworkBridgeConfiguration,org.apache.activemq.transport.Transport,org.apache.activemq.transport.Transport)>(v, v, v);
v = virtualinvoke v.<org.apache.activemq.network.MulticastNetworkConnector: org.apache.activemq.broker.BrokerService getBrokerService()>();
virtualinvoke v.<org.apache.activemq.network.CompositeDemandForwardingBridge: void setBrokerService(org.apache.activemq.broker.BrokerService)>(v);
return v;
}
}