org.apache.tuscany.sca.invocation.Message.getHeaders()方法的使用及代码示例

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

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

Message.getHeaders介绍

[英]Returns a list of objects that are contained in the message header
[中]返回消息头中包含的对象列表

代码示例

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Transfer relevant header information from the old message (incoming) to the new message (outgoing)
  3.  * @param newMsg
  4.  * @param oldMsg
  5.  */
  6. protected void transferMessageHeaders( Message newMsg, Message oldMsg ) {
  7.   if( oldMsg == null ) return;
  8.   // For the present, simply copy all the headers 
  9.   if( !oldMsg.getHeaders().isEmpty() ) newMsg.getHeaders().putAll( oldMsg.getHeaders() );
  10. } // end transferMessageHeaders

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Extracts the RELATES_TO header from the message
  3.  * @param msg - the Tuscany message
  4.  * @return - the value of the RELATES_TO header as a String
  5.  */
  6. private String getMessageRelatesID( Message msg ) {
  7.   return (String)msg.getHeaders().get("RELATES_TO");
  8. } // end method getMessageRelatesID

代码示例来源：origin: org.apache.tuscany.sca/tuscany-policy-security

  1. public static Principal getPrincipal(Message msg){
  2.     
  3.     return (Principal)msg.getHeaders().get(PrincipalString);
  4.   }    
  5. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public static Principal getPrincipal(Message msg){
  2.     
  3.     return (Principal)msg.getHeaders().get(PrincipalString);
  4.   }    
  5. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-policy-security

  1. public static Subject getSubject(Message msg){
  2.   
  3.   Subject subject = (Subject)msg.getHeaders().get(SubjectString);
  4.   
  5.   if (subject == null){
  6.     subject = new Subject(); 
  7.     msg.getHeaders().put(SubjectString, subject); 
  8.   }
  9.   
  10.   return subject;
  11. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public static Subject getSubject(Message msg){
  2.   
  3.   Subject subject = (Subject)msg.getHeaders().get(SubjectString);
  4.   
  5.   if (subject == null){
  6.     subject = new Subject(); 
  7.     msg.getHeaders().put(SubjectString, subject); 
  8.   }
  9.   
  10.   return subject;
  11. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public ResponseDispatchImpl( Message msg ) {
  2.   super();
  3.   
  4.   respInvoker = (AsyncResponseInvoker<?>)msg.getHeaders().get(Constants.ASYNC_RESPONSE_INVOKER);
  5.   //if( respInvoker == null ) throw new ServiceRuntimeException("Async Implementation invoked with no response invoker");
  6.   
  7.   if( respInvoker == null ) {
  8.     callbackRef = getAsyncCallbackRef( msg );
  9.   } // end if 
  10.   
  11.   messageID = (String) msg.getHeaders().get(Constants.MESSAGE_ID);
  12.   
  13. } // end constructor

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-ws-runtime-axis2

  1. /**
  2.  * Handle a SOAP wsa:MessageID header - place the contents into the Tuscany message for use by any callback
  3.  * @param header - the SOAP Headers
  4.  * @param msg - the Tuscany Message
  5.  */
  6. private void handleMessageIDHeader( SOAPHeader header, Message msg ) {
  7.   if( header == null ) return;
  8.   OMElement messageID = header.getFirstChildWithName(QNAME_WSA_MESSAGEID);
  9.   if (messageID != null) {
  10.     String idValue = messageID.getText();
  11.     // Store the value of the message ID element into the message under "WS_MESSAGE_ID"...
  12.     msg.getHeaders().put(Constants.MESSAGE_ID, idValue);
  13.   } // end if
  14. } // end method handleMessageID

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public Subject getSecuritySubject() {
  2.   
  3.   Message msgContext = ThreadMessageContext.getMessageContext();
  4.   
  5.   if (msgContext == null){
  6.     // message in thread context could be null if the user has 
  7.     // spun up a new thread inside their component implementation 
  8.     return null;
  9.   }
  10.   
  11.   Subject subject = null;
  12.   for (Object header : msgContext.getHeaders().values()){
  13.     if (header instanceof Subject){
  14.       subject  = (Subject)header;
  15.       break;
  16.     }
  17.   }
  18.   return subject;
  19. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /** 
  2.  * If you have a Tuscany message you can call this
  3.  */
  4. public void invokeAsyncResponse(Message responseMessage) {
  5.   responseMessage.getHeaders().put(Constants.ASYNC_RESPONSE_INVOKER, this);
  6.   responseMessage.getHeaders().put(Constants.RELATES_TO, relatesToMsgID);
  7.   
  8.   if (isNativeAsync){
  9.     // process the response as a native async response
  10.     requestEndpoint.invokeAsyncResponse(responseMessage);
  11.   } else {
  12.     // process the response as a non-native async response
  13.     responseEndpointReference.invoke(responseMessage);
  14.   }
  15. } // end method invokeAsyncReponse(Message)

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-ws-runtime-axis2

  1. /**
  2.    * Handle a SOAP wsa:RelatesTo header - place the contents into the Tuscany message for use by any callback
  3.    * @param header - the SOAP Headers
  4.    * @param msg - the Tuscany Message
  5.    */
  6.   private void handleRelatesToHeader( SOAPHeader header, Message msg ) {
  7.     if( header == null ) return;
  8.     OMElement messageID = header.getFirstChildWithName(QNAME_WSA_RELATESTO);
  9.     if (messageID != null) {
  10.       String idValue = messageID.getText();
  11.       // Store the value of the message ID element into the message under "RELATES_TO"...
  12.       msg.getHeaders().put(Constants.RELATES_TO, idValue);
  13.     } // end if
  14.   } // end method handleMessageID
  15. } // end class AsyncResponseHandler

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Handle a SOAP wsa:RelatesTo header - place the contents into the Tuscany message for use by any callback
  3.  * @param header - the SOAP Headers
  4.  * @param msg - the Tuscany Message
  5.  */
  6. private void handleRelatesToHeader( SOAPHeader header, Message msg ) {
  7.   if( header == null ) return;
  8.   Iterator<SOAPElement> it = header.getChildElements(QNAME_WSA_RELATESTO);
  9.   SOAPElement relatesTo = it.hasNext() ? it.next() : null;        
  10.   if (relatesTo != null) {
  11.     String relatesToVal = relatesTo.getTextContent();
  12.     msg.getHeaders().put(Constants.RELATES_TO, relatesToVal);
  13.   } // end if
  14. } // end method handleRelatesToHeader

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Handle a SOAP wsa:MessageID header - place the contents into the Tuscany message for use by any callback
  3.  * @param header - the SOAP Headers
  4.  * @param msg - the Tuscany Message
  5.  */
  6. private void handleMessageIDHeader( SOAPHeader header, Message msg ) {
  7.   if( header == null ) return;
  8.   Iterator<SOAPElement> it = header.getChildElements(QNAME_WSA_MESSAGEID);
  9.   SOAPElement messageID = it.hasNext() ? it.next() : null;
  10.   if (messageID != null) {
  11.     String idValue = messageID.getTextContent();
  12.     msg.getHeaders().put(Constants.MESSAGE_ID, idValue);
  13.   } // end if
  14. } // end method handleMessageID

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-jms-runtime

  1. public Message invokeRequest(Message tuscanyMsg) {
  2.   
  3.   try {
  4.   
  5.     javax.jms.Message jmsMsg = tuscanyMsg.getBody();
  6.     
  7.     // Handle MESSAGE_ID field of the JMS message, which is used to correlate async callbacks
  8.     String msgID = (String)jmsMsg.getObjectProperty("MESSAGE_ID");
  9.     if( msgID != null ) {
  10.       tuscanyMsg.getHeaders().put("MESSAGE_ID", msgID);
  11.     } // end if 
  12.     //
  13.   
  14.   } catch (JMSException e) {
  15.     throw new JMSBindingException(e);
  16.   } // end try
  17.   
  18.   return tuscanyMsg;
  19. } // end method invokeRequest

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Sets the values of various headers in the response message
  3.  */
  4. private void setResponseHeaders() {
  5.   // Is there an existing message context?
  6.   Message msgContext = ThreadMessageContext.getMessageContext();
  7.   if( msgContext == null ) {
  8.     // Create a message context
  9.     msgContext = msgFactory.createMessage();
  10.   } // end if
  11.   
  12.   // Add in the header for the RelatesTo Message ID
  13.   msgContext.getHeaders().put(Constants.RELATES_TO, messageID);
  14.   
  15.   ThreadMessageContext.setMessageContext(msgContext);
  16. } // end method setResponseHeaders

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public Message invoke(Message msg) {
  2.   // Deal with async callback
  3.   // Ensure invocation chains are built...
  4.   getInvocationChains();
  5.   // async callback handling
  6.   if( this.isAsyncInvocation() && !this.getCallbackEndpointReferences().isEmpty() ) {
  7.     RuntimeEndpointReference asyncEPR = (RuntimeEndpointReference) this.getCallbackEndpointReferences().get(0);
  8.     // Place a link to the callback EPR into the message headers...
  9.     msg.getHeaders().put(Constants.ASYNC_CALLBACK, asyncEPR );
  10.   } 
  11.   // end of async callback handling
  12.   return invoker.invokeBinding(msg);
  13. }

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. public void invokeAsyncResponse(Message msg) {
  2.   msg = processResponse(msg);
  3.   // Handle async response Relates_To message ID value
  4.   @SuppressWarnings("unchecked")
  5.   AsyncResponseInvoker<RuntimeEndpointReference> respInvoker = 
  6.     (AsyncResponseInvoker<RuntimeEndpointReference>)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");
  7.   // TODO - this deals with the Local case only - not distributed
  8.   if( respInvoker != null && "SCA_LOCAL".equals(respInvoker.getBindingType()) ) {
  9.     RuntimeEndpointReference responseEPR = respInvoker.getResponseTargetAddress();
  10.     msg.setFrom(responseEPR);
  11.     String msgID = respInvoker.getRelatesToMsgID();
  12.     msg.getHeaders().put("RELATES_TO", msgID);
  13.   } // end if
  14.   InvokerAsyncResponse thePrevious = (InvokerAsyncResponse)getPrevious();
  15.   if (thePrevious != null ) thePrevious.invokeAsyncResponse(msg);
  16. } // end method invokeAsyncResponse

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-ws-runtime-axis2

  1. /**
  2.  * Setup the necessary infrastructure for the Async response handling
  3.  * @param msg
  4.  * @param callbackAddress 
  5.  */
  6. private void setupAsyncResponse(Message msg, String callbackAddress) {
  7.   if( !endpoint.isAsyncInvocation() ) return;
  8.   endpoint.createAsyncServerCallback();
  9.   RuntimeEndpointReference asyncCallback = endpoint.getAsyncServerCallback();
  10.   
  11.   // Create a response invoker, containing the callback address and add it to the message headers
  12.   AsyncResponseInvoker<String> respInvoker = 
  13.     new AsyncResponseInvoker<String>(endpoint, asyncCallback,
  14.         callbackAddress, 
  15.         (String)msg.getHeaders().get(Constants.MESSAGE_ID),
  16.         msg.getOperation().getName(), messageFactory);
  17.   msg.getHeaders().put(Constants.ASYNC_RESPONSE_INVOKER, respInvoker);
  18. } // end method setupAsyncResponse

代码示例来源：origin: org.apache.tuscany.sca/tuscany-binding-sca-runtime

  1. public void invokeAsyncResponse(Message msg) {
  2.   msg = processResponse(msg);
  3.   // Handle async response Relates_To message ID value
  4.   @SuppressWarnings("unchecked")
  5.   AsyncResponseInvoker<RuntimeEndpointReference> respInvoker = 
  6.     (AsyncResponseInvoker<RuntimeEndpointReference>)msg.getHeaders().get("ASYNC_RESPONSE_INVOKER");
  7.   // TODO - this deals with the Local case only - not distributed
  8.   if( respInvoker != null && "SCA_LOCAL".equals(respInvoker.getBindingType()) ) {
  9.     RuntimeEndpointReference responseEPR = respInvoker.getResponseTargetAddress();
  10.     msg.setFrom(responseEPR);
  11.     String msgID = respInvoker.getRelatesToMsgID();
  12.     msg.getHeaders().put("RELATES_TO", msgID);
  13.   } // end if
  14.   InvokerAsyncResponse thePrevious = (InvokerAsyncResponse)getPrevious();
  15.   if (thePrevious != null ) thePrevious.invokeAsyncResponse(msg);
  16. } // end method invokeAsyncResponse

代码示例来源：origin: org.apache.tuscany.sca/tuscany-base-runtime

  1. /**
  2.  * Creates a service reference for the async callback, based on information contained in the supplied message
  3.  * @param msg - the incoming message
  4.  * @return - a CallBackServiceReference
  5.  */
  6. @SuppressWarnings("unchecked")
  7. private ServiceReference<AsyncResponseHandler<?>> getAsyncCallbackRef( Message msg ) { 
  8.   RuntimeEndpointReference callbackEPR = (RuntimeEndpointReference) msg.getHeaders().get(Constants.ASYNC_CALLBACK);
  9.   if( callbackEPR == null ) return null;
  10.   
  11.   CompositeContext compositeContext = callbackEPR.getCompositeContext();
  12.   registry = compositeContext.getExtensionPointRegistry();
  13.   ProxyFactory proxyFactory = ExtensibleProxyFactory.getInstance(registry);
  14.   msgFactory = getMessageFactory();
  15.   List<EndpointReference> eprList = new ArrayList<EndpointReference>();
  16.   eprList.add(callbackEPR);
  17.   ObjectFactory<?> factory = new CallbackReferenceObjectFactory(AsyncResponseHandler.class, proxyFactory, eprList);
  18.   
  19.   return (ServiceReference<AsyncResponseHandler<?>>) factory.getInstance();
  20.   
  21. } // end method getAsyncCallbackEPR

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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