protected void doNotify(Element content) { try { DeliveryChannel channel = context.getDeliveryChannel(); MessageExchangeFactory factory = channel.createExchangeFactory(endpoint); InOnly inonly = factory.createInOnlyExchange(); NormalizedMessage msg = inonly.createMessage(); inonly.setInMessage(msg); msg.setContent(new DOMSource(content)); if (!channel.sendSync(inonly)) { log.warn("Notification was aborted"); } } catch (JBIException e) { log.warn("Could not deliver notification", e); }
protected void doNotify(final Element content) { try { DeliveryChannel channel = getContext().getDeliveryChannel(); MessageExchangeFactory factory = channel.createExchangeFactory(endpoint); InOnly inonly = factory.createInOnlyExchange(); NormalizedMessage msg = inonly.createMessage(); inonly.setInMessage(msg); msg.setContent(new DOMSource(content)); getLifeCycle().sendConsumerExchange(inonly, processor); } catch (JBIException e) { log.warn("Could not deliver notification", e); }
	protected void doNotify(Element content) {		try {			DeliveryChannel channel = context.getDeliveryChannel();			MessageExchangeFactory factory = channel.createExchangeFactory(endpoint);			InOnly inonly = factory.createInOnlyExchange();			NormalizedMessage msg = inonly.createMessage();			inonly.setInMessage(msg);			msg.setContent(new DOMSource(content));			if (!channel.sendSync(inonly)) {				log.warn("Notification was aborted");			}		} catch (JBIException e) {			log.warn("Could not deliver notification", e);		}	}