Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- try {
- _managementComponent.channelAES.sendMessage(requestMsg.getBytes());
- String s = "";
- try {
- //while ((s = bufferedReader.readLine()) != null) {
- while ((s = new String(_managementComponent.channelAES.receiveMessage())) != null) {
- System.out.println("MESSAGE = " + s);
- System.out.println(s.startsWith("Not"));
- if (s.startsWith("!engines")) {
- break;
- }
- else if (s.startsWith("Not")) {
- System.out.println("AAA");
- throw new RemoteException("Not enough capacity.");
- }
- else if (s.startsWith("No")) {
- throw new RemoteException("No engines available.");
- }
- }
- } catch (IOException e1) {
- throw new RemoteException(e1.getMessage());
- }
Add Comment
Please, Sign In to add comment