public class org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler extends java.lang.Object implements org.apache.camel.component.jms.reply.ReplyHandler
{
protected final org.apache.camel.component.jms.reply.ReplyManager replyManager;
protected final org.apache.camel.Exchange exchange;
protected final org.apache.camel.AsyncCallback callback;
protected final java.lang.String originalCorrelationId;
protected final java.lang.String correlationId;
protected final long timeout;
public void <init>(org.apache.camel.component.jms.reply.ReplyManager, org.apache.camel.Exchange, org.apache.camel.AsyncCallback, java.lang.String, java.lang.String, long)
{
org.apache.camel.component.jms.reply.ReplyManager v;
org.apache.camel.AsyncCallback v;
long v;
org.apache.camel.Exchange v;
java.lang.String v, v;
org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler v;
v := @this: org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler;
v := @parameter: org.apache.camel.component.jms.reply.ReplyManager;
v := @parameter: org.apache.camel.Exchange;
v := @parameter: org.apache.camel.AsyncCallback;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: long;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.component.jms.reply.ReplyManager replyManager> = v;
v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.Exchange exchange> = v;
v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: java.lang.String originalCorrelationId> = v;
v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: java.lang.String correlationId> = v;
v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.AsyncCallback callback> = v;
v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: long timeout> = v;
return;
}
public void onReply(java.lang.String, javax.jms.Message, javax.jms.Session)
{
org.apache.camel.component.jms.reply.ReplyManager v;
org.apache.camel.AsyncCallback v;
org.apache.camel.Exchange v;
org.apache.camel.component.jms.reply.ReplyHolder v;
javax.jms.Session v;
java.lang.String v, v;
javax.jms.Message v;
org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler v;
v := @this: org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler;
v := @parameter: java.lang.String;
v := @parameter: javax.jms.Message;
v := @parameter: javax.jms.Session;
v = new org.apache.camel.component.jms.reply.ReplyHolder;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.Exchange exchange>;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.AsyncCallback callback>;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: java.lang.String originalCorrelationId>;
specialinvoke v.<org.apache.camel.component.jms.reply.ReplyHolder: void <init>(org.apache.camel.Exchange,org.apache.camel.AsyncCallback,java.lang.String,java.lang.String,javax.jms.Message,javax.jms.Session)>(v, v, v, v, v, v);
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.component.jms.reply.ReplyManager replyManager>;
interfaceinvoke v.<org.apache.camel.component.jms.reply.ReplyManager: void processReply(org.apache.camel.component.jms.reply.ReplyHolder)>(v);
return;
}
public void onTimeout(java.lang.String)
{
org.apache.camel.component.jms.reply.ReplyManager v;
org.apache.camel.AsyncCallback v;
long v;
org.apache.camel.Exchange v;
org.apache.camel.component.jms.reply.ReplyHolder v;
java.lang.String v, v;
org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler v;
v := @this: org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler;
v := @parameter: java.lang.String;
v = new org.apache.camel.component.jms.reply.ReplyHolder;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.Exchange exchange>;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.AsyncCallback callback>;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: java.lang.String originalCorrelationId>;
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: long timeout>;
specialinvoke v.<org.apache.camel.component.jms.reply.ReplyHolder: void <init>(org.apache.camel.Exchange,org.apache.camel.AsyncCallback,java.lang.String,java.lang.String,long)>(v, v, v, v, v);
v = v.<org.apache.camel.component.jms.reply.TemporaryQueueReplyHandler: org.apache.camel.component.jms.reply.ReplyManager replyManager>;
interfaceinvoke v.<org.apache.camel.component.jms.reply.ReplyManager: void processReply(org.apache.camel.component.jms.reply.ReplyHolder)>(v);
return;
}
}