Mule

Tcp Streaming Message Receiver based on PollingMessageReceiver

Details

  • Type: New Feature New Feature
  • Status: Closed Closed
  • Priority: Minor Minor
  • Resolution: Fixed
  • Affects Version/s: 2.0.0-M1
  • Fix Version/s: 2.0.0-M1
  • Labels:
    None
  • Environment:

    Windows 2000 SP4, Java JDK 1.4.2_10, Mule development snapshot

  • Similar Issues:
    MULE-1242 Non-materializing streaming receiver for TCP
    MULE-1490 Mina based TCP transport
    MULE-2396 Rewrite the VMMessageReceiver to not extend PollingMessageReceiver
    MULE-1678 Streaming Model Re-Dispatching Empty Streams
    MULE-103 Tcp provider not handling large messages
    MULE-525 TCP protocol to divide streaming data into xml messages using xml declaration
    MULE-1502 Unify SSL and TCP Architecture
    MULE-2152 TCP message receiver sending data back even if it is not suppose to
    MULE-2448 Streaming Model Should set TCP Protocol?
    MULE-248 Tcp Provider not handling large messages

Description

TcpStreamingMessageReceiver establishes a tcp client connection to an external server and reads the streaming data. No polling frequency is used since with blocking i/o reads will block, and with non-blocking i/o reads will occur when data is available. Causing delays between read attempts is unnecessary, so this forces the pollingFrequency property to zero so no pause occurs in the PollingMessageReceiver class. This class should be combined with XmlMessageProtocol or LengthProtocol in the config file to properly break up the stream into messages.

Activity

Hide
Rich Lucente added a comment - 20/Dec/05 12:00 PM

Attached my implementation. Sorry no test case

Show
Rich Lucente added a comment - 20/Dec/05 12:00 PM Attached my implementation. Sorry no test case
Hide
Andrew Perepelytsya added a comment - 10/Oct/06 10:46 AM

All old Resolved issues transitioned into a Closed state.

Show
Andrew Perepelytsya added a comment - 10/Oct/06 10:46 AM All old Resolved issues transitioned into a Closed state.

People

Vote (0)
Watch (0)

Dates

  • Created:
    20/Dec/05 11:59 AM
    Updated:
    10/Oct/06 10:46 AM
    Resolved:
    21/Dec/05 10:59 PM