[Beepcore-java-commits] CVS: beepcore-java GettingStarted.txt,1.2,1.3
Status: Beta
Brought to you by:
huston
From: Huston F. <hu...@us...> - 2002-09-14 02:13:45
|
Update of /cvsroot/beepcore-java/beepcore-java In directory usw-pr-cvs1:/tmp/cvs-serv18020 Modified Files: GettingStarted.txt Log Message: cleanup Index: GettingStarted.txt =================================================================== RCS file: /cvsroot/beepcore-java/beepcore-java/GettingStarted.txt,v retrieving revision 1.2 retrieving revision 1.3 diff -C2 -r1.2 -r1.3 *** GettingStarted.txt 25 Apr 2001 07:06:05 -0000 1.2 --- GettingStarted.txt 14 Sep 2002 02:13:42 -0000 1.3 *************** *** 47,57 **** Session using: ! Session session = AutomatedTCPSessionCreator.initiate(host, port, ! new ProfileRegistry()); From a listener's role you can listen for new Sessions using: while (true) { ! AutomatedTCPSessionCreator.listen(port, profileReg); } --- 47,57 ---- Session using: ! Session session = TCPSessionCreator.initiate(host, port, ! new ProfileRegistry()); From a listener's role you can listen for new Sessions using: while (true) { ! TCPSessionCreator.listen(port, profileReg); } *************** *** 90,108 **** ------------------ ! The abstraction for the data of a message is a DataStream. Before ! sending a message one of the DataStream types (StringDataStream, ! ByteDataStream, etc.) must be created. ! DataStream dataStream = ! new StringDataStream("<attach endpoint=\"fr...@ex...\"/>"); NOTE: BEEP has a flow control mechanism for Channels that makes it possible to have multiple channels on one connection. The flow control ! is tied into the DataStream so that as an application reads the data ! it notifies Channel that more data may be received. Because of this ! the application MUST either read all of the data in the received ! messages or call close on the DataStreams for the messages to allow ! more data to be sent on the Channel. If this is not done the Channel ! will stall once the window for the Channel is full and no more messages will be received on that Channel. --- 90,108 ---- ------------------ ! The abstraction for the data of a message is an ! OutputDataStream. Before sending a message one of the OutputDataStream ! types (StringDataStream, ByteDataStream, etc.) must be created. ! OutputDataStream dataStream = ! new StringOutputDataStream("<attach endpoint=\"fr...@ex...\"/>"); NOTE: BEEP has a flow control mechanism for Channels that makes it possible to have multiple channels on one connection. The flow control ! is tied into the InputDataStream so that as an application reads the ! data it notifies Channel that more data may be received. Because of ! this the application MUST either read all of the data in the received ! messages or call close on the InputDataStreams for the messages to ! allow more data to be sent on the Channel. If this is not done the ! Channel will stall once the window for the Channel is full and no more messages will be received on that Channel. *************** *** 125,130 **** A reply must be sent for each request. This may be a RPY, ERR, or an ! ANS/NUL set. They are sent using the coresponding methods on Channel ! (sendRPY, etc.). ANS messages are a mechanism for sending multiple messages as a reply --- 125,130 ---- A reply must be sent for each request. This may be a RPY, ERR, or an ! ANS/NUL set. They are sent using the coresponding methods on ! MessageMSG (sendRPY, etc.). ANS messages are a mechanism for sending multiple messages as a reply *************** *** 139,143 **** startChannel callback in StartChannelListener). ! channel.setDataListener(this); Basic Server --- 139,143 ---- startChannel callback in StartChannelListener). ! channel.setMessageListener(this); Basic Server *************** *** 153,157 **** echo.getStartChannelListener()); while (true) { ! AutomatedTCPSessionCreator.listen(port, reg); } --- 153,157 ---- echo.getStartChannelListener()); while (true) { ! TCPSessionCreator.listen(port, reg); } *************** *** 166,170 **** try { ! message.getChannel().sendRPY(message.getDataStream()); } catch (BEEPException e) { throw new BEEPError(BEEPError.CODE_REQUESTED_ACTION_ABORTED, --- 166,170 ---- try { ! message.sendRPY(message.getDataStream()); } catch (BEEPException e) { throw new BEEPError(BEEPError.CODE_REQUESTED_ACTION_ABORTED, *************** *** 178,194 **** (see example Bing) ! Session session = AutomatedTCPSessionCreator.initiate(host, port, ! new ProfileRegistry()); Channel channel = session.startChannel(EchoProfile.ECHO_URI); Reply reply = new Reply(); ! channel.sendMSG(new StringDataStream("Hello"), reply); ! DataStream ds = reply.getNextReply().getDataStream(); ! InputStream is = ds.getInputStream(); ! int replyLength = 0; ! while (ds.isComplete() == false || is.available() > 0) { ! is.read(); ++replyLength; } --- 178,193 ---- (see example Bing) ! Session session = TCPSessionCreator.initiate(host, port, ! new ProfileRegistry()); Channel channel = session.startChannel(EchoProfile.ECHO_URI); Reply reply = new Reply(); ! channel.sendMSG(new StringOutputDataStream("Hello"), reply); ! InputStream is = ! reply.getNextReply().getDataStream().getInputStream(); ! // Read the data in the reply ! while (is.read() != -1) { ++replyLength; } |