Package org.activeio.packet

Examples of org.activeio.packet.ByteArrayPacket

95
96
97
98
99
100
101
102
103
104
105
                  Subject subject = Subject.getSubject(AccessController.getContext());
                  String p = subject.getPrincipals().iterator().next().toString();
                  log.info("Sending request as: "+p);

                    Packet request = new ByteArrayPacket("whoami".getBytes());
                    Packet response = channel.request(request, 1000*5*1000);

                    assertNotNull(response);
                    assertEquals( p, new String(response.sliceAsBytes()) );
                    return null;
View Full Code Here
219
220
221
222
223
224
225
          p = subject.getPrincipals().iterator().next().toString();
          log.info("Received request as: "+p);
        } catch ( Exception e ) {
            e.printStackTrace();
        }
        return new ByteArrayPacket(p.getBytes());
    }
View Full Code Here
164
165
166
167
168
169
170
        os.writeByte(SET_SUBJECT);
        os.writeLong(subjectId.longValue());
        os.writeInt(hash.length);
        os.close();
        header.flip();
        return AppendedPacket.join(header, new ByteArrayPacket(hash));
    }
View Full Code Here
46
47
48
49
50
51
52
    protected void setUp() throws Exception {
        File file = new File("target/journal");
        JournalTestHelper.delete(file);
        journal = new JournalImpl(file);
        packet = new ByteArrayPacket(new byte[1072]);
    }
View Full Code Here
46
47
48
49
50
51
52
    protected void setUp() throws Exception {
        File file = new File("target/journal");
        JournalTestHelper.delete(file);
        journal = new JournalImpl(file);
        packet = new ByteArrayPacket(new byte[1072]);
    }
View Full Code Here
TOP

Related Classes of org.activeio.packet.ByteArrayPacket

  • org.activeio.adapter.AsynchChannelOutputStream
  • org.activeio.adapter.AsynchChannelToConcurrentRequestChannel
  • org.activeio.adapter.PacketByteArrayOutputStream
  • org.activeio.adapter.SynchChannelOutputStream
  • org.activeio.ChannelRequestTestSupport
  • org.activeio.filter.WriteBufferedAsynchChannel
  • org.activeio.filter.WriteBufferedSynchChannel
  • org.activeio.journal.active.JournalImplTest
  • org.activeio.journal.active.LogFileManager
  • org.activeio.journal.active.LogFileManagerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.