Created
June 16, 2012 12:37
-
-
Save cjmamo/2941235 to your computer and use it in GitHub Desktop.
Mule meet ZeroMQ. ZeroMQ meet Mule.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<flow name="MultipartInboundFlow"> | |
<zeromq:inbound-endpoint address="tcp://*:9090" socket-operation="bind" | |
exchange-pattern="pull"/> | |
<expression-transformer evaluator="groovy" expression="payload[3]"/> | |
... | |
</flow> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<flow name="BackendFlow"> | |
<zeromq:inbound-endpoint address="tcp://*:9090" socket-operation="bind" | |
exchange-pattern="request-response"/> | |
... | |
</flow> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<flow name="MultipartOutboundFlow"> | |
... | |
<expression-transformer evaluator="groovy" | |
expression="['1st part', '2nd part', '3rd part', '4th part', '5th part']"/> | |
<zeromq:outbound-endpoint address="tcp://192.168.34.10:9090" | |
socket-operation="connect" multipart="true" exchange-pattern="push"/> | |
</flow> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<flow name="FrontEndFlow"> | |
<http:inbound-endpoint address="http://localhost:8080/frontend"/> | |
<zeromq:outbound-endpoint address="tcp://192.168.34.10:9090" | |
socket-operation="connect" exchange-pattern="one-way"/> | |
</flow> |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<?xml version="1.0" encoding="UTF-8"?> | |
<mule xmlns="http://www.mulesoft.org/schema/mule/core" | |
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" | |
xmlns:http="http://www.mulesoft.org/schema/mule/http" | |
xmlns:zeromq="http://www.mulesoft.org/schema/mule/zeromq" | |
xsi:schemaLocation=" | |
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd | |
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd | |
http://www.mulesoft.org/schema/mule/zeromq http://www.mulesoft.org/schema/mule/zeromq/1.0/mule-zeromq.xsd"> | |
<flow name="FrontEndFlow"> | |
<http:inbound-endpoint address="http://localhost:8080/frontend"/> | |
<zeromq:outbound-endpoint address="tcp://192.168.34.10:9090" | |
socket-operation="connect" exchange-pattern="request-response"/> | |
</flow> | |
</mule> |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment