@Test public void testCreateProcessingPayload() throws Exception{ String partner = "partnerC"; String msg = "msg3"; PackagedPayloads pp = (PackagedPayloads) repo.createPayloads(new Object[]{"partnerC", "msg3"}, PayloadsState.PLS_PROCESSING); Assert.assertEquals("Partnership id not match", partner, pp.getPartnershipId()); Assert.assertEquals("Message id not match", msg, pp.getRefMessageId()); }
public NamedPayloads createPayloads(Object[] params, int initialState) throws Exception { if (params.length < 2) throw new IllegalArgumentException( "Not enough parameters for creating payload."); String payloadName = params[0].toString() + NamedPayloads.decodeDelimiters + params[1].toString() + PACKAGE_EXT; PackagedPayloads pp = new PackagedPayloads(payloadName, initialState, this); return pp; }
PackagedPayloadsRepository extends PayloadsRepository { public NamedPayloads createPayloads(Object[] params, int initialState) throws Exception { if (params.length < 2) throw new IllegalArgumentException( "Not enough parameters for creating payload."); String payloadName = params[0].toString() + NamedPayloads.decodeDelimiters + params[1].toString() + PACKAGE_EXT; PackagedPayloads pp = new PackagedPayloads(payloadName, initialState, this); return pp; } }
PackagedPayloadsRepository extends PayloadsRepository { public NamedPayloads createPayloads(Object[] params, int initialState) throws Exception { if (params.length < 2) throw new IllegalArgumentException( "Not enough parameters for creating payload."); String payloadName = params[0].toString() + NamedPayloads.decodeDelimiters + params[1].toString() + PACKAGE_EXT; PackagedPayloads pp = new PackagedPayloads(payloadName, initialState, this); return pp; }  }
PackagedPayloadsRepository extends PayloadsRepository { public NamedPayloads createPayloads(Object[] params, int initialState) throws Exception { if (params.length < 2) throw new IllegalArgumentException( "Not enough parameters for creating payload."); String payloadName = params[0].toString() + NamedPayloads.decodeDelimiters + params[1].toString() + PACKAGE_EXT; PackagedPayloads pp = new PackagedPayloads(payloadName, initialState, this); return pp; }  Collection getReadyPayloads(); Collection getPayloads(); Collection getProcessingPayloads(); NamedPayloads createPayloads(Object[] params, int initialState); NamedPayloads getPayload(Object[] params, int state); String toString(); static void main(String args[]); }
PackagedPayloadsRepository extends PayloadsRepository { public NamedPayloads createPayloads(Object[] params, int initialState) throws Exception { if (params.length < 2) throw new IllegalArgumentException( "Not enough parameters for creating payload."); String payloadName = params[0].toString() + NamedPayloads.decodeDelimiters + params[1].toString() + PACKAGE_EXT; PackagedPayloads pp = new PackagedPayloads(payloadName, initialState, this); return pp; }  Collection getReadyPayloads(); Collection getPayloads(); Collection getProcessingPayloads(); NamedPayloads createPayloads(Object[] params, int initialState); NamedPayloads getPayload(Object[] params, int state); String toString(); static void main(String args[]); static final String PACKAGE_EXT; }