fixed breakage
This commit is contained in:
@@ -30,7 +30,7 @@ import org.springframework.integration.annotation.Gateway;
|
|||||||
*/
|
*/
|
||||||
public interface Cafe {
|
public interface Cafe {
|
||||||
|
|
||||||
@Gateway(requestChannel="preOrders")
|
@Gateway(requestChannel="orders")
|
||||||
void placeOrder(Order order);
|
void placeOrder(Order order);
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -27,9 +27,9 @@
|
|||||||
|
|
||||||
<int-amqp:inbound-channel-adapter queue-names="new-orders" channel="jsonOrders" connection-factory="rabbitConnectionFactory" acknowledge-mode="AUTO" />
|
<int-amqp:inbound-channel-adapter queue-names="new-orders" channel="jsonOrders" connection-factory="rabbitConnectionFactory" acknowledge-mode="AUTO" />
|
||||||
|
|
||||||
<int:json-to-object-transformer id="json-to-order" input-channel="jsonOrders" output-channel="orders" type="org.springframework.integration.samples.cafe.Order" />
|
<int:json-to-object-transformer id="json-to-order" input-channel="jsonOrders" output-channel="preOrders" type="org.springframework.integration.samples.cafe.Order" />
|
||||||
|
|
||||||
<int:splitter input-channel="orders" expression="payload.items" output-channel="preDrinks" apply-sequence="true"/>
|
<int:splitter input-channel="preOrders" expression="payload.items" output-channel="preDrinks" apply-sequence="true"/>
|
||||||
|
|
||||||
<int:header-enricher input-channel="preDrinks" output-channel="drinks">
|
<int:header-enricher input-channel="preDrinks" output-channel="drinks">
|
||||||
<int:header name="ICED" expression="payload.isIced()"/>
|
<int:header name="ICED" expression="payload.isIced()"/>
|
||||||
|
|||||||
@@ -25,9 +25,9 @@
|
|||||||
<!-- spring integration flow -->
|
<!-- spring integration flow -->
|
||||||
<int:gateway id="cafe" service-interface="org.springframework.integration.samples.cafe.Cafe" />
|
<int:gateway id="cafe" service-interface="org.springframework.integration.samples.cafe.Cafe" />
|
||||||
|
|
||||||
<int:channel id="preOrders"/>
|
<int:channel id="orders"/>
|
||||||
|
|
||||||
<int:header-enricher input-channel="preOrders" output-channel="newOrders">
|
<int:header-enricher input-channel="orders" output-channel="newOrders">
|
||||||
<int:header name="NUMBER" expression="payload.getNumber()"/>
|
<int:header name="NUMBER" expression="payload.getNumber()"/>
|
||||||
</int:header-enricher>
|
</int:header-enricher>
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user