Prev | Current Page 193 | Next

Binildas A Christudas

"Service-Oriented Java Business Integration"

getStatus() == ExchangeStatus.DONE)
{
return;
}
else if (exchange.getStatus() == ExchangeStatus.ERROR)
{
return;
}
try
{
Developing JBI Components
[ 138 ]
InOnly outExchange = null;
NormalizedMessage in = getInMessage(exchange);
NormalizedMessage out;
if (isInAndOut(exchange))
{
out = exchange.createMessage();
}
else
{
outExchange = getExchangeFactory().createInOnlyExchange();
out = outExchange.createMessage();
}
boolean txSync = exchange.isTransacted() && Boolean.TRUE.
equals(exchange.getProperty(JbiConstants.SEND_SYNC));
copyPropertiesAndAttachments(exchange, in, out);
if (transform(exchange, in, out))
{
if (isInAndOut(exchange))
{
exchange.setMessage(out, "out");
if (txSync)
{
getDeliveryChannel().sendSync(exchange);
}
else
{
getDeliveryChannel().send(exchange);
}
}
else
{
outExchange.setMessage(out, "in");
if (txSync)
{
getDeliveryChannel().sendSync(outExchange);
}
else
{
getDeliveryChannel().send(outExchange);
}
Chapter 7
[ 139 ]
exchange.setStatus(ExchangeStatus.DONE);
getDeliveryChannel().send(exchange);
}
}
else
{
exchange.


Pages:
181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205