class org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory extends java.lang.Object implements reactor.io.net.NetStreams$TcpClientFactory
{
private final java.lang.String host;
private final int port;
private final reactor.io.net.impl.netty.NettyClientSocketOptions socketOptions;
private final reactor.Environment environment;
private final org.springframework.messaging.simp.stomp.Reactor2StompCodec codec;
void <init>(java.lang.String, int, io.netty.channel.EventLoopGroup, reactor.Environment)
{
org.springframework.messaging.simp.stomp.StompDecoder v;
io.netty.channel.EventLoopGroup v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory v;
int v;
reactor.io.net.impl.netty.NettyClientSocketOptions v, v;
java.lang.String v;
org.springframework.messaging.simp.stomp.StompEncoder v;
reactor.Environment v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: io.netty.channel.EventLoopGroup;
v := @parameter: reactor.Environment;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: java.lang.String host> = v;
v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: int port> = v;
v = new reactor.io.net.impl.netty.NettyClientSocketOptions;
specialinvoke v.<reactor.io.net.impl.netty.NettyClientSocketOptions: void <init>()>();
v = virtualinvoke v.<reactor.io.net.impl.netty.NettyClientSocketOptions: reactor.io.net.impl.netty.NettyClientSocketOptions eventLoopGroup(io.netty.channel.EventLoopGroup)>(v);
v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: reactor.io.net.impl.netty.NettyClientSocketOptions socketOptions> = v;
v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: reactor.Environment environment> = v;
v = new org.springframework.messaging.simp.stomp.Reactor2StompCodec;
v = new org.springframework.messaging.simp.stomp.StompEncoder;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompEncoder: void <init>()>();
v = new org.springframework.messaging.simp.stomp.StompDecoder;
specialinvoke v.<org.springframework.messaging.simp.stomp.StompDecoder: void <init>()>();
specialinvoke v.<org.springframework.messaging.simp.stomp.Reactor2StompCodec: void <init>(org.springframework.messaging.simp.stomp.StompEncoder,org.springframework.messaging.simp.stomp.StompDecoder)>(v, v);
v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: org.springframework.messaging.simp.stomp.Reactor2StompCodec codec> = v;
return;
}
public reactor.io.net.Spec$TcpClientSpec apply(reactor.io.net.Spec$TcpClientSpec)
{
reactor.core.Dispatcher v;
reactor.bus.spec.DispatcherComponentSpec v, v;
org.springframework.messaging.simp.stomp.Reactor2StompCodec v;
org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory v;
int v;
reactor.io.net.impl.netty.NettyClientSocketOptions v;
java.lang.String v;
reactor.Environment v, v;
reactor.io.net.Spec$TcpClientSpec v, v, v, v;
v := @this: org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory;
v := @parameter: reactor.io.net.Spec$TcpClientSpec;
v = v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: reactor.Environment environment>;
v = virtualinvoke v.<reactor.io.net.Spec$TcpClientSpec: reactor.bus.spec.DispatcherComponentSpec env(reactor.Environment)>(v);
v = v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: reactor.Environment environment>;
v = virtualinvoke v.<reactor.Environment: reactor.core.Dispatcher getDispatcher(java.lang.String)>("workQueue");
v = virtualinvoke v.<reactor.io.net.Spec$TcpClientSpec: reactor.bus.spec.DispatcherComponentSpec dispatcher(reactor.core.Dispatcher)>(v);
v = v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: java.lang.String host>;
v = v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: int port>;
v = virtualinvoke v.<reactor.io.net.Spec$TcpClientSpec: reactor.io.net.Spec$TcpClientSpec connect(java.lang.String,int)>(v, v);
v = v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: org.springframework.messaging.simp.stomp.Reactor2StompCodec codec>;
v = virtualinvoke v.<reactor.io.net.Spec$TcpClientSpec: reactor.io.net.Spec$TcpClientSpec codec(reactor.io.codec.Codec)>(v);
v = v.<org.springframework.messaging.simp.stomp.Reactor2TcpStompClient$StompTcpClientSpecFactory: reactor.io.net.impl.netty.NettyClientSocketOptions socketOptions>;
v = virtualinvoke v.<reactor.io.net.Spec$TcpClientSpec: reactor.io.net.Spec$TcpClientSpec options(reactor.io.net.config.ClientSocketOptions)>(v);
return v;
}
}