INT-1552 general pollishing of several docs to address coments on this JIRA
This commit is contained in:
@@ -260,7 +260,7 @@
|
||||
|
||||
<para>Spring Integration provides an out-of-the box implementation for
|
||||
<code>ReleaseStrategy</code>, the
|
||||
<code>SequenceSizerReleaseStrategy</code>. This implementation uses the
|
||||
<code>SequenceSizeReleaseStrategy</code>. This implementation uses the
|
||||
SEQUENCE_NUMBER and SEQUENCE_SIZE of the arriving messages for deciding
|
||||
when a message group is complete and ready to be aggregated. As shown
|
||||
above, it is also the default strategy.</para>
|
||||
@@ -683,7 +683,7 @@
|
||||
}]]></programlisting>
|
||||
|
||||
<para>The expireMessageGroups method can be called with a timeout value:
|
||||
any message older than the current time minus this value wiull be expired,
|
||||
any message older than the current time minus this value will be expired,
|
||||
and have the callbacks applied. Thus it is the user of the store that
|
||||
defines what is meant by message group "expiry".</para>
|
||||
|
||||
|
||||
@@ -65,7 +65,7 @@ subscribableChannel.subscribe(messageHandler);
|
||||
Since a handler that is subscribed to a channel does not have to actively poll that channel, this is an
|
||||
Event Driven Consumer, and the implementation provided by Spring Integration accepts a
|
||||
a <interfacename>SubscribableChannel</interfacename> and a <interfacename>MessageHandler</interfacename>:
|
||||
<programlisting language="java">SubscribableChannel channel = (SubscribableChannel) context.getBean("subscribableChannel");
|
||||
<programlisting language="java">SubscribableChannel channel = context.getBean("subscribableChannel", SubscribableChannel.class);
|
||||
|
||||
EventDrivenConsumer consumer = new EventDrivenConsumer(channel, exampleHandler);</programlisting>
|
||||
</para>
|
||||
@@ -76,7 +76,7 @@ EventDrivenConsumer consumer = new EventDrivenConsumer(channel, exampleHandler);
|
||||
<para>
|
||||
Spring Integration also provides a <classname>PollingConsumer</classname>, and it can be instantiated in
|
||||
the same way except that the channel must implement <interfacename>PollableChannel</interfacename>:
|
||||
<programlisting language="java">PollableChannel channel = (PollableChannel) context.getBean("pollableChannel");
|
||||
<programlisting language="java">PollableChannel channel = context.getBean("pollableChannel", PollableChannel.class);
|
||||
|
||||
PollingConsumer consumer = new PollingConsumer(channel, exampleHandler);</programlisting>
|
||||
</para>
|
||||
@@ -131,10 +131,10 @@ consumer.setReceiveTimeout(5000);</programlisting>
|
||||
<programlisting language="java">
|
||||
PollingConsumer consumer = new PollingConsumer(channel, handler);
|
||||
|
||||
TaskExecutor taskExecutor = (TaskExecutor) context.getBean("exampleExecutor");
|
||||
TaskExecutor taskExecutor = context.getBean("exampleExecutor", TaskExecutor.class);
|
||||
consumer.setTaskExecutor(taskExecutor);
|
||||
|
||||
PlatformTransactionManager txManager = (PlatformTransationManager) context.getBean("exampleTxManager");
|
||||
PlatformTransactionManager txManager = context.getBean("exampleTxManager", PlatformTransationManager.class);
|
||||
consumer.setTransactionManager(txManager);</programlisting>
|
||||
The examples above show dependency lookups, but keep in mind that these consumers will most often be configured
|
||||
as Spring <emphasis>bean definitions</emphasis>. In fact, Spring Integration also provides a
|
||||
|
||||
@@ -105,7 +105,8 @@ By default the HTTP request will be generated using an instance of <classname>Si
|
||||
<para>
|
||||
To configure an inbound http channel adapter which is an instance of <classname>HttpInboundEndpoint</classname> configured
|
||||
not to expect a response.
|
||||
<programlisting language="xml"><![CDATA[ <http:inbound-channel-adapter id="httpChannelAdapter" channel="requests" supported-methods="PUT, DELETE"/>]]></programlisting>
|
||||
<programlisting language="xml"><![CDATA[<http:inbound-channel-adapter id="httpChannelAdapter" channel="requests"
|
||||
supported-methods="PUT, DELETE"/>]]></programlisting>
|
||||
</para>
|
||||
<para>
|
||||
To configure an inbound http gateway which expects a response.
|
||||
|
||||
@@ -155,7 +155,7 @@
|
||||
</para>
|
||||
<para>
|
||||
As with anything else, Gateway invocation might result in error.
|
||||
By default Producer will not be notified of the errors thta might have occurredon ythe consumer side and will time out waiting for
|
||||
By default Producer will not be notified of the errors that might have occurred on the consumer side and will time out waiting for
|
||||
the reply. However there might be times when you want to communicate an error condition back to the consumer,
|
||||
in other words treat the Exception as a valid reply by mapping it to a Message. To accomplish this
|
||||
JMS Inbound Gateway provides support for a Message Channel to which errors
|
||||
|
||||
@@ -9,7 +9,7 @@
|
||||
Spring Integration provides support for outbound email with the
|
||||
<classname>MailSendingMessageHandler</classname>. It delegates to a configured instance of Spring's
|
||||
<interfacename>JavaMailSender</interfacename>:
|
||||
<programlisting language="java"> JavaMailSender mailSender = (JavaMailSender) context.getBean("mailSender");
|
||||
<programlisting language="java"> JavaMailSender mailSender = context.getBean("mailSender", JavaMailSender.class);
|
||||
|
||||
MailSendingMessageHandler mailSendingHandler = new MailSendingMessageHandler(mailSender);</programlisting>
|
||||
<classname>MailSendingMessageHandler</classname> has various mapping strategies that use Spring's
|
||||
|
||||
@@ -564,7 +564,7 @@ That includes Samples, so if you can't find what you are looking for let us know
|
||||
else {
|
||||
context = new ClassPathXmlApplicationContext("cafeDemo.xml", CafeDemo.class);
|
||||
}
|
||||
Cafe cafe = (Cafe) context.getBean("cafe");
|
||||
Cafe cafe = context.getBean("cafe", Cafe.class);
|
||||
for (int i = 1; i <= 100; i++) {
|
||||
Order order = new Order(i);
|
||||
order.addItem(DrinkType.LATTE, 2, false);
|
||||
|
||||
Reference in New Issue
Block a user