Package javax.jbi.messaging

Examples of javax.jbi.messaging.DeliveryChannel.send()

82
83
84
85
86
87
88
89
90
91
92
            MessageExchangeFactory outputFactory = deliveryChannel.createExchangeFactory(outputEndpoint);
            InOnly inOnly = outputFactory.createInOnlyExchange();
   
            if (answer) {
                inOnly.setInMessage(rpc.getOutMessage());
                deliveryChannel.send(inOnly);
                done(exchange);
            }
            else if (exchange instanceof InOnly == false) {
                inOnly.setError(rpc.getError());
                Fault fault = rpc.getFault();
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
            me.setProperty(name, exchange.getProperty(name));
        }
        if (Boolean.TRUE.equals(exchange.getProperty(JbiConstants.SEND_SYNC))) {
            channel.sendSync(me);
        } else {
            channel.send(me);
        }
    }

  public Flow getFlow() {
    return flow;
View Full Code Here
98
99
100
101
102
103
104
105
106
107
108
                DeliveryChannel deliveryChannel = context.getDeliveryChannel();
                System.out.println("sync send on deliverychannel: " + deliveryChannel);
                if (sync) {
                  deliveryChannel.sendSync(exchange);
                } else {
                  deliveryChannel.send(exchange);
                }
            }
        }
        else {
            log.warn("No endpoints available for interface: " + interfaceName);
View Full Code Here
120
121
122
123
124
125
126
127
128
129
130
                Fault f = me.getFault();
                Fault of = exchange.createFault();
                exchange.setFault(of);
                getMessageTransformer().transform(exchange, f, of);
            }
            channel.send(exchange);
            done(me);
        }
       
    }
View Full Code Here
111
112
113
114
115
116
117
118
119
120
121
              me.setProperty(name, exchange.getProperty(name));
          }
          if (Boolean.TRUE.equals(exchange.getProperty(JbiConstants.SEND_SYNC))) {
              channel.sendSync(me);
          } else {
              channel.send(me);
          }
      }
    }

  public String getFlowName() {
View Full Code Here
242
243
244
245
246
247
248
249
250
251
252
            InOnly inonly = factory.createInOnlyExchange();
            inonly.setService(ReceiverComponent.SERVICE);
            NormalizedMessage msg = inonly.createMessage();
            msg.setContent(src);
            inonly.setInMessage(msg);
            channel.send(inonly);
        }
       
        public Source twoWay(Source src) throws Exception {
            DeliveryChannel channel = context.getDeliveryChannel();
            MessageExchangeFactory factory = channel.createExchangeFactory();
View Full Code Here
256
257
258
259
260
261
262
263
264
265
266
            msg.setContent(src);
            inout.setInMessage(msg);
            channel.sendSync(inout);
            Source outSrc = inout.getOutMessage().getContent();
            inout.setStatus(ExchangeStatus.DONE);
            channel.send(inout);
            return outSrc;
        }
    }
   
}
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
                    if (!channel.sendSync(me)) {
                        throw new XFireException("Unable to send jbi exchange: sendSync returned false");
                    }
                    if (me.getStatus() == ExchangeStatus.ERROR) {
                        me.setStatus(ExchangeStatus.DONE);
                        channel.send(me);
                        if (me.getError() != null) {
                            throw new XFireFault(me.getError(), XFireFault.RECEIVER);
                        } else if (me.getFault() != null){
                            // TODO: retrieve fault
                            throw new XFireFault("Fault received", XFireFault.RECEIVER);
View Full Code Here
107
108
109
110
111
112
113
114
115
116
117
                            throw new XFireFault("Unkown Error", XFireFault.RECEIVER);
                        }
                    }
                    Source outSrc = me.getOutMessage().getContent();
                    me.setStatus(ExchangeStatus.DONE);
                    channel.send(me);

                    InMessage inMessage = new InMessage(sourceTransformer.toXMLStreamReader(outSrc), getUri());
                    getEndpoint().onReceive(context, inMessage);
                } else {
                    // TODO
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
            boolean sent = channel.sendSync(inout);
            // TODO: check for error ?
            NormalizedMessage out = inout.getOutMessage();
            Object response = context.createUnmarshaller().unmarshal(out.getContent());
            inout.setStatus(ExchangeStatus.DONE);
            channel.send(inout);
            return response;
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.