diff options
| author | schmidt <douglascraigschmidt@users.noreply.github.com> | 1999-03-16 17:19:05 +0000 |
|---|---|---|
| committer | schmidt <douglascraigschmidt@users.noreply.github.com> | 1999-03-16 17:19:05 +0000 |
| commit | 2ee189878f5e890ca465e3816150a7ac9bbc1f9a (patch) | |
| tree | 6e3555c8eb24cadd46ea2663a21ce64b7731bb25 /examples | |
| parent | f7dabd0f0b951336bae741ce669b61e50a9c4f58 (diff) | |
| download | ATCD-2ee189878f5e890ca465e3816150a7ac9bbc1f9a.tar.gz | |
.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/ASX/Message_Queue/buffer_stream.cpp | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/examples/ASX/Message_Queue/buffer_stream.cpp b/examples/ASX/Message_Queue/buffer_stream.cpp index f022f6a9447..02911c02a46 100644 --- a/examples/ASX/Message_Queue/buffer_stream.cpp +++ b/examples/ASX/Message_Queue/buffer_stream.cpp @@ -261,7 +261,7 @@ main (int, char *argv[]) MT_Module *fm; MT_Module *cm; - ACE_NEW_RETURN (pm, + ACE_NEW_RETURN (cm, MT_Module ("Consumer", new Consumer), -1); @@ -269,15 +269,15 @@ main (int, char *argv[]) MT_Module ("Filter", new Filter), -1); - ACE_NEW_RETURN (cm, + ACE_NEW_RETURN (pm, MT_Module ("Producer", new Producer), -1); - // Create Producer and Consumer Modules and push them onto the - // Stream. All processing is performed in the Stream. + // Create Consumer, Filter, and Producer Modules and push them onto + // the Stream. All processing is performed in the Stream. - if (stream.push (pm) == -1) + if (stream.push (cm) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "push"), @@ -287,7 +287,7 @@ main (int, char *argv[]) "%p\n", "push"), 1); - else if (stream.push (cm) == -1) + else if (stream.push (pm) == -1) ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "push"), |