org.fabric3.spi.container.invocation.Message.setWorkContext()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(8.8k)|赞(0)|评价(0)|浏览(256)

本文整理了Java中org.fabric3.spi.container.invocation.Message.setWorkContext()方法的一些代码示例，展示了Message.setWorkContext()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Message.setWorkContext()方法的具体详情如下：
包路径：org.fabric3.spi.container.invocation.Message
类名称：Message
方法名：setWorkContext

Message.setWorkContext介绍

[英]Sets the context associated with this invocation.
[中]设置与此调用关联的上下文。

代码示例

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-zeromq

  1. public void run() {
  2.     Message request = MessageCache.getAndResetMessage();
  3.     try {
  4.       request.setBody(frames[0]);
  5.       int methodIndex = ByteBuffer.wrap(frames[1]).getInt();
  6.       WorkContext context = setWorkContext(frames[2]);
  7.       request.setWorkContext(context);
  8.       Interceptor interceptor = interceptors[methodIndex];
  9.       interceptor.invoke(request);
  10.     } finally {
  11.       request.reset();
  12.     }
  13.   }
  14. });

代码示例来源：origin: org.fabric3/fabric3-binding-ws-metro

  1. public Object invoke(Packet packet, Method method, Object... args) throws InvocationTargetException {
  2.   // the work context is populated by the current tubeline
  3.   WorkContext workContext = (WorkContext) packet.invocationProperties.get(MetroConstants.WORK_CONTEXT);
  4.   if (workContext == null) {
  5.     // programming error
  6.     throw new AssertionError("Work context not set");
  7.   }
  8.   Message input = MessageCache.getAndResetMessage();
  9.   try {
  10.     input.setWorkContext(workContext);
  11.     input.setBody(args);
  12.     Interceptor head = chains.get(method.getName()).getHeadInterceptor();
  13.     Message ret = head.invoke(input);
  14.     if (!ret.isFault()) {
  15.       return ret.getBody();
  16.     } else {
  17.       Throwable th = (Throwable) ret.getBody();
  18.       throw new InvocationTargetException(th);
  19.     }
  20.   } finally {
  21.     input.reset();
  22.   }
  23. }

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-ws

  1. public Object invoke(Packet packet, Method method, Object... args) throws InvocationTargetException {
  2.   // the work context is populated by the current tubeline
  3.   WorkContext workContext = (WorkContext) packet.invocationProperties.get(MetroConstants.WORK_CONTEXT);
  4.   if (workContext == null) {
  5.     // programming error
  6.     throw new AssertionError("Work context not set");
  7.   }
  8.   Message input = MessageCache.getAndResetMessage();
  9.   try {
  10.     input.setWorkContext(workContext);
  11.     input.setBody(args);
  12.     Interceptor head = chains.get(method.getName()).getHeadInterceptor();
  13.     Message ret = head.invoke(input);
  14.     if (!ret.isFault()) {
  15.       return ret.getBody();
  16.     } else {
  17.       Throwable th = (Throwable) ret.getBody();
  18.       throw new InvocationTargetException(th);
  19.     }
  20.   } finally {
  21.     input.reset();
  22.   }
  23. }

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-zeromq

  1. public void run() {
  2.     Message request = MessageCache.getAndResetMessage();
  3.     try {
  4.       request.setBody(frames[0]);
  5.       int methodIndex = ByteBuffer.wrap(frames[1]).getInt();
  6.       WorkContext context = setWorkContext(frames[2]);
  7.       request.setWorkContext(context);
  8.       Interceptor interceptor = interceptors[methodIndex];
  9.       // invoke the service
  10.       Message response = interceptor.invoke(request);
  11.       Object responseBody = response.getBody();
  12.       if (!(responseBody instanceof byte[])) {
  13.         throw new ServiceRuntimeException("Return value not serialized");
  14.       }
  15.       // queue the response
  16.       try {
  17.         queue.put(new Response(clientId, (byte[]) responseBody));
  18.       } catch (InterruptedException e) {
  19.         Thread.interrupted();
  20.       }
  21.     } finally {
  22.       request.reset();
  23.       //                    context.reset();
  24.     }
  25.   }
  26. });

代码示例来源：origin: org.fabric3/fabric3-binding-ws-metro

  1. Node node = soapMessage.getSOAPBody().extractContentAsDocument();
  2. input.setWorkContext(workContext);
  3. input.setBody(node);
  4. String operationName = packet.getWSDLOperation().getLocalPart();

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-rs-jersey

  1. public Object invoke(Method method, Object[] args) throws Throwable {
  2.   InvocationChain invocationChain = chains.get(method.getName());
  3.   if (invocationChain == null) {
  4.     throw new ServiceRuntimeException("Unknown resource method: " + method.toString());
  5.   }
  6.   WorkContext context = WorkContextCache.getThreadWorkContext();   // work context set previously in RsContainer
  7.   Message message = MessageCache.getAndResetMessage();
  8.   try {
  9.     message.setWorkContext(context);
  10.     message.setBody(args);
  11.     if (invocationChain != null) {
  12.       Interceptor headInterceptor = invocationChain.getHeadInterceptor();
  13.       Message ret = headInterceptor.invoke(message);
  14.       if (ret.isFault()) {
  15.         return handleFault(ret);
  16.       } else {
  17.         return ret.getBody();
  18.       }
  19.     } else {
  20.       return null;
  21.     }
  22.   } catch (RuntimeException e) {
  23.     throw new InvocationTargetException(e);
  24.   } finally {
  25.     message.reset();
  26.   }
  27. }

代码示例来源：origin: org.fabric3/fabric3-binding-rs-jersey

  1. public Object invoke(Method method, Object[] args) throws Throwable {
  2.   InvocationChain invocationChain = chains.get(method.getName());
  3.   if (invocationChain == null) {
  4.     throw new ServiceRuntimeException("Unknown resource method: " + method.toString());
  5.   }
  6.   WorkContext context = WorkContextCache.getThreadWorkContext();   // work context set previously in RsContainer
  7.   Message message = MessageCache.getAndResetMessage();
  8.   try {
  9.     message.setWorkContext(context);
  10.     message.setBody(args);
  11.     if (invocationChain != null) {
  12.       Interceptor headInterceptor = invocationChain.getHeadInterceptor();
  13.       Message ret = headInterceptor.invoke(message);
  14.       if (ret.isFault()) {
  15.         return handleFault(ret);
  16.       } else {
  17.         return ret.getBody();
  18.       }
  19.     } else {
  20.       return null;
  21.     }
  22.   } catch (RuntimeException e) {
  23.     throw new InvocationTargetException(e);
  24.   } finally {
  25.     message.reset();
  26.   }
  27. }

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-jms

  1. WorkContext workContext = setWorkContext(request);
  2. org.fabric3.spi.container.invocation.Message inMessage = MessageCache.getAndResetMessage();
  3. inMessage.setWorkContext(workContext);
  4. inMessage.setBody(payload);

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-file

  1. Message message = MessageCache.getAndResetMessage();
  2. try {
  3.   message.setWorkContext(workContext);
  4.   Message response = dispatch(payload, message);
  5.   afterInvoke(file, payload);

代码示例来源：origin: org.fabric3/fabric3-binding-ws-metro

  1. public boolean handleMessage(SOAPMessageContext smc) {
  2.   Boolean outbound = (Boolean) smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
  3.   WorkContext workContext = WorkContextCache.getThreadWorkContext();
  4.   workContext = (WorkContext) (workContext == null ? smc.get(MetroConstants.WORK_CONTEXT) : workContext);
  5.   if (workContext == null) {
  6.     throw new ServiceRuntimeException("Work context not set");
  7.   }
  8.   if (outbound) {
  9.     // reference proxy outbound or service invocation return
  10.     Message msg = MessageCache.getMessage();
  11.     if (msg.getWorkContext() == null) {
  12.       // service invocation return
  13.       msg.setBody(smc.getMessage());
  14.       msg.setWorkContext(workContext);
  15.     }
  16.     delegateHandler.handleOutbound(msg, smc.getMessage());
  17.   } else {
  18.     // reference proxy invocation return or service invocation
  19.     Message msg = MessageCache.getMessage();
  20.     if (msg.getWorkContext() == null) {
  21.       // reference proxy return
  22.       msg.setBody(smc.getMessage());
  23.       msg.setWorkContext(workContext);
  24.     }
  25.     delegateHandler.handleInbound(smc.getMessage(), msg);
  26.     msg.reset();
  27.   }
  28.   return true;
  29. }

代码示例来源：origin: com.carecon.fabric3/fabric3-binding-ws

  1. public boolean handleMessage(SOAPMessageContext smc) {
  2.   Boolean outbound = (Boolean) smc.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
  3.   WorkContext workContext = WorkContextCache.getThreadWorkContext();
  4.   workContext = (WorkContext) (workContext == null ? smc.get(MetroConstants.WORK_CONTEXT) : workContext);
  5.   if (workContext == null) {
  6.     throw new ServiceRuntimeException("Work context not set");
  7.   }
  8.   if (outbound) {
  9.     // reference proxy outbound or service invocation return
  10.     Message msg = MessageCache.getMessage();
  11.     if (msg.getWorkContext() == null) {
  12.       // service invocation return
  13.       msg.setBody(smc.getMessage());
  14.       msg.setWorkContext(workContext);
  15.     }
  16.     delegateHandler.handleOutbound(msg, smc.getMessage());
  17.   } else {
  18.     // reference proxy invocation return or service invocation
  19.     Message msg = MessageCache.getMessage();
  20.     if (msg.getWorkContext() == null) {
  21.       // reference proxy return
  22.       msg.setBody(smc.getMessage());
  23.       msg.setWorkContext(workContext);
  24.     }
  25.     delegateHandler.handleInbound(smc.getMessage(), msg);
  26.     msg.reset();
  27.   }
  28.   return true;
  29. }

代码示例来源：origin: org.fabric3/fabric3-jdk-proxy

  1. message.setWorkContext(workContext);
  2. try {

代码示例来源：origin: com.carecon.fabric3/fabric3-async

  1. public void run() {
  2.   WorkContext workContext = WorkContextCache.getAndResetThreadWorkContext();
  3.   workContext.addCallbackReferences(stack);
  4.   workContext.addHeaders(headers);
  5.   workContext.setSubject(subject);
  6.   Message message = MessageCache.getAndResetMessage();
  7.   message.setBody(payload);
  8.   message.setWorkContext(workContext);
  9.   Message response = next.invoke(message);
  10.   if (response.isFault()) {
  11.     // log the exception
  12.     monitor.onError((Throwable) response.getBody());
  13.   }
  14.   message.reset();
  15.   workContext.reset();
  16. }

代码示例来源：origin: com.carecon.fabric3/fabric3-jdk-proxy

  1. message.setWorkContext(workContext);
  2. try {

代码示例来源：origin: org.fabric3/fabric3-binding-ftp

  1. public boolean onUpload(String fileName, String contentType, InputStream uploadData) throws Exception {
  2.   Object[] args = new Object[]{fileName, uploadData};
  3.   WorkContext workContext = WorkContextCache.getAndResetThreadWorkContext();
  4.   Message input = MessageCache.getAndResetMessage();
  5.   try {
  6.     // set the header value for the request context
  7.     workContext.setHeader(FtpConstants.HEADER_CONTENT_TYPE, contentType);
  8.     input.setWorkContext(workContext);
  9.     input.setBody(args);
  10.     Message response = getInterceptor().invoke(input);
  11.     if (response.isFault()) {
  12.       monitor.fileProcessingError(servicePath, (Throwable) response.getBody());
  13.       input.reset();
  14.       return false;
  15.     }
  16.     return true;
  17.   } finally {
  18.     input.reset();
  19.     workContext.reset();
  20.   }
  21. }

代码示例来源：origin: com.carecon.fabric3/fabric3-jdk-proxy

  1. message.setWorkContext(workContext);
  2. try {

代码示例来源：origin: org.fabric3/fabric3-jdk-proxy

  1. message.setWorkContext(workContext);
  2. try {

内容来源于网络，如有侵权，请联系作者删除！

Message

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com