本文整理了Java中org.switchyard.Message.getContent()
方法的一些代码示例,展示了Message.getContent()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.getContent()
方法的具体详情如下:
包路径:org.switchyard.Message
类名称:Message
方法名:getContent
[英]Returns the content from the body of the message.
[中]返回消息正文中的内容。
代码示例来源:origin: org.switchyard/switchyard-test
@Override
public Throwable getCause() {
if (Throwable.class.isAssignableFrom(_faultMessage.getContent().getClass())) {
return _faultMessage.getContent(Throwable.class);
} else {
return super.getCause();
}
}
}
代码示例来源:origin: jboss-switchyard/core
@Override
public Throwable getCause() {
if (Throwable.class.isAssignableFrom(_faultMessage.getContent().getClass())) {
return _faultMessage.getContent(Throwable.class);
} else {
return super.getCause();
}
}
}
代码示例来源:origin: org.switchyard.components/switchyard-component-bean
private static Object[] castArg(Method method, Message message) {
if (method.getParameterTypes().length == 1 && message != null) {
return new Object[]{message.getContent(method.getParameterTypes()[0])};
}
return null;
}
代码示例来源:origin: jboss-switchyard/components
private static Object[] castArg(Method method, Message message) {
if (method.getParameterTypes().length == 1 && message != null) {
return new Object[]{message.getContent(method.getParameterTypes()[0])};
}
return null;
}
代码示例来源:origin: org.switchyard.components/switchyard-component-bean
/**
* {@inheritDoc}
*/
@Override
public Object getContent() {
return getMessage().getContent();
}
代码示例来源:origin: org.switchyard.components/switchyard-component-bean
/**
* {@inheritDoc}
*/
@Override
public <T> T getContent(Class<T> type) {
return getMessage().getContent(type);
}
代码示例来源:origin: jboss-switchyard/components
/**
* {@inheritDoc}
*/
@Override
public <T> T getContent(Class<T> type) {
return getMessage().getContent(type);
}
代码示例来源:origin: org.switchyard.components/switchyard-component-common-knowledge
private static List<Object> getInputList(Message message, List<ExpressionMapping> inputs, KnowledgeRuntimeEngine runtime) {
List<Object> list = new ArrayList<Object>();
if (inputs.size() > 0) {
list.addAll(getList(message, inputs));
} else {
expand(filterRemoteDefaultInputContent(message.getContent(), runtime), list);
}
return list;
}
代码示例来源:origin: jboss-switchyard/components
private static List<Object> getInputList(Message message, List<ExpressionMapping> inputs, KnowledgeRuntimeEngine runtime) {
List<Object> list = new ArrayList<Object>();
if (inputs.size() > 0) {
list.addAll(getList(message, inputs));
} else {
expand(filterRemoteDefaultInputContent(message.getContent(), runtime), list);
}
return list;
}
代码示例来源:origin: org.switchyard.components/switchyard-component-common-knowledge
@Override
public void handleFault(Exchange exchange) {
_fault = exchange.getMessage().getContent();
super.handleFault(exchange);
}
}
代码示例来源:origin: jboss-switchyard/components
@Override
public void handleFault(Exchange exchange) {
_fault = exchange.getMessage().getContent();
super.handleFault(exchange);
}
}
代码示例来源:origin: jboss-switchyard/components
private static List<Object> getList(Message message, List<ExpressionMapping> expressionMappings) {
List<Object> list = new ArrayList<Object>();
if (expressionMappings == null || expressionMappings.size() == 0) {
expand(message.getContent(), list);
} else {
Map<String, List<Object>> listMap = getListMap(message, expressionMappings, true, toVariable(message));
for (List<Object> value : listMap.values()) {
expand(value, list);
}
}
return list;
}
代码示例来源:origin: org.switchyard.components/switchyard-component-common-knowledge
private static List<Object> getList(Message message, List<ExpressionMapping> expressionMappings) {
List<Object> list = new ArrayList<Object>();
if (expressionMappings == null || expressionMappings.size() == 0) {
expand(message.getContent(), list);
} else {
Map<String, List<Object>> listMap = getListMap(message, expressionMappings, true, toVariable(message));
for (List<Object> value : listMap.values()) {
expand(value, list);
}
}
return list;
}
代码示例来源:origin: jboss-switchyard/core
@Test
public void testContent() throws Exception {
final String message = "Hello There!";
_message.setContent(message);
Assert.assertEquals(message, _message.getContent());
// the following tests to make sure casting to same type works
String content = _message.getContent(String.class);
Assert.assertEquals(message, content);
}
代码示例来源:origin: jboss-switchyard/core
@Override
public void handleMessage(Exchange exchange) throws HandlerException {
String content = (String) exchange.getMessage().getContent();
if (content.equals("Hello there, SwitchYard")) {
success=true;
}
}
}
代码示例来源:origin: org.switchyard.quickstarts/switchyard-bean-service
@Override
public void after(String target, Exchange exchange) throws HandlerException {
// We only want to intercept successful replies from OrderService
if (exchange.getProvider().getName().getLocalPart().equals("OrderService")
&& ExchangeState.OK.equals(exchange.getState())) {
OrderAck orderAck = exchange.getMessage().getContent(OrderAck.class);
orderAck.setStatus(orderAck.getStatus() + " [intercepted]");
}
}
代码示例来源:origin: org.switchyard.quickstarts/switchyard-quickstart-http-binding
/**
* {@inheritDoc}
*/
@Override
public HttpBindingData decompose(Exchange exchange, HttpBindingData target) throws Exception {
Object content = exchange.getMessage().getContent();
if ((content instanceof String) && (content.equals(""))) {
exchange.getContext().setProperty(HttpContextMapper.HTTP_RESPONSE_STATUS, 404).addLabels(new String[]{EndpointLabel.HTTP.label()});
}
target = super.decompose(exchange, target);
return target;
}
代码示例来源:origin: jboss-switchyard/release
@Override
public org.switchyard.Message compose(JMSBindingData source, Exchange exchange) throws Exception {
org.switchyard.Message msg = super.compose(source, exchange);
msg.setContent(msg.getContent(String.class) + "test");
return msg;
}
代码示例来源:origin: jboss-switchyard/components
/**
* {@inheritDoc}
*/
@SuppressWarnings("unchecked")
@Override
public IndexedRecordBindingData decompose(Exchange exchange, IndexedRecordBindingData target) throws Exception {
Message sourceMessage = exchange.getMessage();
getContextMapper().mapTo(exchange.getContext(), target);
final List<?> content = sourceMessage.getContent(List.class);
target.getRecord().addAll(content);
return target;
}
代码示例来源:origin: jboss-switchyard/release
@Override
public JMSBindingData decompose(Exchange exchange, JMSBindingData target) throws Exception {
exchange.getMessage().setContent(exchange.getMessage().getContent(String.class)+"test");
return super.decompose(exchange, target);
}
内容来源于网络,如有侵权,请联系作者删除!