Uploaded image for project: 'Spring Integration'
  1. Spring Integration
  2. INT-3335

Implement an int-mongo:outbound-gateway

    XMLWordPrintable

    Details

    • Type: New Feature
    • Status: Closed
    • Priority: Minor
    • Resolution: Complete
    • Affects Version/s: None
    • Fix Version/s: 5.0.M2
    • Component/s: MongoDB Support
    • Labels:

      Description

      Hi,

      Our use case is, a request is received on http, which contains request parameters that we want to use to create and
      execute a query on mongoDB and process the response.

      We tries achieving this using "mongodb:inbound-channel-adapter", and found we restrictions.

      1) Is there a way to use "mongodb:inbound-channel-adapter", without any POLLER.

      2) And also is there a way to invoke "mongodb:inbound-channel-adapter" from a "http:inbound-gateway" element?

      Please suggest.

      <int-http:inbound-gateway id="PRICE-IG-Gateway" path="/price/stores/v1/10001"
      	request-channel="PRICE-IG-request-channel" reply-channel="PRICE-IG-response-channel"
      	supported-methods="GET" reply-timeout="1000" payload-expression="#queryParam">
      </int-http:inbound-gateway>
      	
      <int-mongodb:inbound-channel-adapter id="priceInboundAdapter"
      		channel="PRICE-IG-response-channel" query="<expression>"
      		entity-class="domain.PriceOutputVO" collection-name="price"
      		mongodb-factory="mongoDbFactory" mongo-converter="mongoConverter" query-expression="">
      	<int:poller fixed-rate="0" max-messages-per-poll="1" />
      </int-mongodb:inbound-channel-adapter>
      

      P.S: Using Spring version: 3.2.6.RELEASE

      Thanks,
      Shwetha

        Attachments

          Activity

            People

            Assignee:
            abilan Artem Bilan
            Reporter:
            srani Shwetha Rani
            Votes:
            0 Vote for this issue
            Watchers:
            4 Start watching this issue

              Dates

              Created:
              Updated:
              Resolved: