org.apache.cxf.message.Message.getContextualProperty()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(7.5k)|赞(0)|评价(0)|浏览(302)

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

Message.getContextualProperty介绍

[英]Queries the Message object's metadata for a specific property.
[中]查询消息对象的元数据以获取特定属性。

代码示例

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. private boolean isClientDisconnected(Throwable ex) {
  2.   String exName = (String)inMessage.getContextualProperty("disconnected.client.exception.class");
  3.   if (exName != null) {
  4.     return exName.equals(IOException.class.getName()) || exName.equals(ex.getClass().getName());
  5.   }
  6.   return false;
  7. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. private boolean logSensitiveHeaders() {
  2.   // Not allowed by default
  3.   return PropertyUtils.isTrue(message.getContextualProperty(ALLOW_LOGGING_SENSITIVE_HEADERS));
  4. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. private static void checkAllowedRedirectUri(String conduitName,
  2.                       String lastURL,
  3.                       String newURL,
  4.                       Message message) throws IOException {
  5.   if (newURL != null) {
  6.     URI newUri = URI.create(newURL);
  7.     if (MessageUtils.getContextualBoolean(message, AUTO_REDIRECT_SAME_HOST_ONLY)) {
  8.       URI lastUri = URI.create(lastURL);
  9.       // This can be further restricted to make sure newURL completely contains lastURL
  10.       // though making sure the same HTTP scheme and host are preserved should be enough
  11.       if (!newUri.getScheme().equals(lastUri.getScheme())
  12.         || !newUri.getHost().equals(lastUri.getHost())) {
  13.         String msg = "Different HTTP Scheme or Host Redirect detected on Conduit '"
  14.           + conduitName + "' on '" + newURL + "'";
  15.         LOG.log(Level.INFO, msg);
  16.         throw new IOException(msg);
  17.       }
  18.     }
  19.     String allowedRedirectURI = (String)message.getContextualProperty(AUTO_REDIRECT_ALLOWED_URI);
  20.     if (allowedRedirectURI != null && !newURL.startsWith(allowedRedirectURI)) {
  21.       String msg = "Forbidden Redirect URI " + newURL + "detected on Conduit '" + conduitName;
  22.       LOG.log(Level.INFO, msg);
  23.       throw new IOException(msg);
  24.     }
  25.   }
  26. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. public Servlet3Continuation() {
  2.   req.setAttribute(AbstractHTTPDestination.CXF_CONTINUATION_MESSAGE,
  3.            inMessage.getExchange().getInMessage());
  4.   callback = inMessage.getExchange().get(ContinuationCallback.class);
  5.   blockRestart = PropertyUtils.isTrue(inMessage.getContextualProperty(BLOCK_RESTART));
  6.   context = req.startAsync();
  7.   context.addListener(this);
  8. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. public String getAuthorization(AuthorizationPolicy  authPolicy,
  2.                 URI currentURI,
  3.                 Message message,
  4.                 String fullHeader) {
  5.   if (authPolicy.getUserName() != null && authPolicy.getPassword() != null) {
  6.     boolean encodeBasicAuthWithIso8859 = PropertyUtils.isTrue(
  7.       message.getContextualProperty(ENCODE_BASIC_AUTH_WITH_ISO8859));
  8.     return getBasicAuthHeader(authPolicy.getUserName(),
  9.                  authPolicy.getPassword(),
  10.                  encodeBasicAuthWithIso8859);
  11.   }
  12.   return null;
  13. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. (GSSCredential)message.getContextualProperty(GSSCredential.class.getName());

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. Object setCtForEmptyRequestProp = message.getContextualProperty(SET_EMPTY_REQUEST_CT_PROPERTY);

代码示例来源：origin: apache/cxf

  1. @SuppressWarnings("unchecked")
  2. private <T, Y> SearchConditionVisitor<T, Y> getVisitor() {
  3.   Object visitor = message.getContextualProperty(SearchUtils.SEARCH_VISITOR_PROPERTY);
  4.   if (visitor == null) {
  5.     return null;
  6.   }
  7.   //TODO: consider introducing SearchConditionVisitor.getBeanClass &&
  8.   //      SearchConditionVisitor.getQueryClass to avoid such casts
  9.   return (SearchConditionVisitor<T, Y>)visitor;
  10. }

代码示例来源：origin: org.apache.cxf/cxf-rt-transports-http

  1. public void handleMessage(Message message) throws Fault {
  2.   final CertConstraints certConstraints
  3.     = (CertConstraints)message.getContextualProperty(CertConstraints.class.getName());
  4.   if (certConstraints == null) {
  5.     return;

代码示例来源：origin: apache/cxf

  1. public static String getKeyAlgorithm(Message m, Properties props, String propName, String defaultAlg) {
  2.   String algo = props != null ? props.getProperty(propName) : null;
  3.   if (algo == null && m != null) {
  4.     algo = (String)m.getContextualProperty(propName);
  5.   }
  6.   if (algo == null) {
  7.     algo = defaultAlg;
  8.   }
  9.   return algo;
  10. }

代码示例来源：origin: apache/cxf

  1. private static void mapSecurityProps(Message message, Map<String, Object> ctx) {
  2.   for (String s : SecurityConstants.ALL_PROPERTIES) {
  3.     Object v = message.getContextualProperty(s);
  4.     if (v != null) {
  5.       ctx.put(s, v);
  6.     }
  7.   }
  8. }

代码示例来源：origin: org.apache.cxf/cxf-core

  1. public static Integer getInteger(Message message, String key) {
  2.     Object o = message.getContextualProperty(key);
  3.     if (o instanceof Integer) {
  4.       return (Integer)o;
  5.     } else if (o instanceof Number) {
  6.       return ((Number)o).intValue();
  7.     } else if (o instanceof String) {
  8.       return Integer.valueOf((String)o);
  9.     }
  10.     return null;
  11.   }
  12. }

代码示例来源：origin: apache/cxf

  1. public static URL getConfigFileURL(Message message, String configFileKey, String configFileDefault) {
  2.   Object o = message.getContextualProperty(configFileKey);
  3.   if (o == null) {
  4.     o = configFileDefault;
  5.   }
  6.   return loadResource(message, o);
  7. }

代码示例来源：origin: apache/cxf

  1. protected BeanValidationProvider getProvider(Message message) {
  2.   if (provider == null) {
  3.     Object prop = message.getContextualProperty(BeanValidationProvider.class.getName());
  4.     if (prop != null) {
  5.       provider = (BeanValidationProvider)prop;
  6.     } else {
  7.       provider = new BeanValidationProvider();
  8.     }
  9.   }
  10.   return provider;
  11. }

代码示例来源：origin: org.apache.cxf/cxf-rt-frontend-jaxws

  1. public void setPayload(Source s) {
  2.   Message message = msgContext.getWrappedMessage();
  3.   Service.Mode mode = (Service.Mode)msgContext.getWrappedMessage()
  4.     .getContextualProperty(Service.Mode.class.getName());
  5.   SOAPMessage m = message.getContent(SOAPMessage.class);
  6.   if (m != null && !MessageUtils.isOutbound(message)) {

代码示例来源：origin: apache/cxf

  1. protected boolean shouldBuffer(Message message) {
  2.   Object en = message.getContextualProperty(OUT_BUFFERING);
  3.   boolean allowBuffer = true;
  4.   boolean buffer = false;
  5.   if (en != null) {
  6.     buffer = Boolean.TRUE.equals(en) || "true".equals(en);
  7.     allowBuffer = !(Boolean.FALSE.equals(en) || "false".equals(en));
  8.   }
  9.   // need to cache the events in case validation fails or buffering is enabled
  10.   return buffer || (allowBuffer && shouldValidate(message) && !isRequestor(message));
  11. }

代码示例来源：origin: apache/cxf

  1. public Object getContextualProperty(Object key) {
  2.   Object value = m.getContextualProperty(key.toString());
  3.   if (value == null && key.getClass() == Class.class) {
  4.     return m.getExchange().get((Class<?>)key);
  5.   }
  6.   return value;
  7. }

代码示例来源：origin: apache/cxf

  1. public static Properties loadEncryptionOutProperties(boolean required) {
  2.   Message m = PhaseInterceptorChain.getCurrentMessage();
  3.   String keyEncryptionAlgorithm =
  4.     (String)m.getContextualProperty(JoseConstants.RSSEC_ENCRYPTION_KEY_ALGORITHM);
  5.   if (keyEncryptionAlgorithm != null && AlgorithmUtils.PBES_HS_SET.contains(keyEncryptionAlgorithm)) {
  6.     // We don't need to load the keystore properties for the PBES case
  7.     required = false;
  8.   }
  9.   return KeyManagementUtils.loadStoreProperties(m, required,
  10.                          JoseConstants.RSSEC_ENCRYPTION_OUT_PROPS,
  11.                          JoseConstants.RSSEC_ENCRYPTION_PROPS);
  12. }

代码示例来源：origin: apache/cxf

  1. @Override
  2. public <T> T getResource(Class<T> cls) {
  3.   ResourceProvider rp = null;
  4.   Object propValue = m.getContextualProperty(CONTEXT_PROVIDER_PROP);
  5.   if (propValue instanceof ResourceContextProvider) {
  6.     rp = ((ResourceContextProvider)propValue).getResourceProvider(cls);
  7.   } else {
  8.     rp = new PerRequestResourceProvider(cls);
  9.   }
  10.   T resource = cls.cast(rp.getInstance(m));
  11.   return doInitResource(cls, resource);
  12. }

代码示例来源：origin: apache/cxf

  1. public Servlet3Continuation() {
  2.   req.setAttribute(AbstractHTTPDestination.CXF_CONTINUATION_MESSAGE,
  3.            inMessage.getExchange().getInMessage());
  4.   callback = inMessage.getExchange().get(ContinuationCallback.class);
  5.   blockRestart = PropertyUtils.isTrue(inMessage.getContextualProperty(BLOCK_RESTART));
  6.   context = req.startAsync();
  7.   context.addListener(this);
  8. }

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

Message

相关文章

    查看更多

    热门标签

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

    最新文章

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