| 21 | } |
| 22 | |
| 23 | int |
| 24 | Writer::svc () |
| 25 | { |
| 26 | ACE_DEBUG ((LM_DEBUG, |
| 27 | ACE_TEXT ("(%P|%t) Writer::svc begins.\n"))); |
| 28 | |
| 29 | try |
| 30 | { |
| 31 | Messenger::MessageDataWriter_var message_dw = |
| 32 | Messenger::MessageDataWriter::_narrow (writer_.in ()); |
| 33 | |
| 34 | if (CORBA::is_nil (message_dw.in ())) |
| 35 | { |
| 36 | cerr << "Data Writer could not be narrowed"<< endl; |
| 37 | exit(1); |
| 38 | } |
| 39 | |
| 40 | Messenger::Message message1; |
| 41 | message1.subject_id = 1; |
| 42 | Messenger::Message message2; |
| 43 | message2.subject_id = 2; |
| 44 | |
| 45 | ACE_DEBUG((LM_DEBUG, |
| 46 | ACE_TEXT ("(%P|%t) %T Writer::svc starting to write.\n"))); |
| 47 | |
| 48 | this->write (message_dw.in (), message1); |
| 49 | this->write (message_dw.in (), message2); |
| 50 | } |
| 51 | catch (CORBA::Exception& e) |
| 52 | { |
| 53 | cerr << "Exception caught in svc:" << endl |
| 54 | << e << endl; |
| 55 | } |
| 56 | |
| 57 | ACE_DEBUG ((LM_DEBUG, ACE_TEXT("(%P|%t) Writer::svc finished.\n"))); |
| 58 | |
| 59 | return 0; |
| 60 | } |
| 61 | |
| 62 | bool |
| 63 | Writer::start () |