Package org.mokai.persist.mongo

Examples of org.mokai.persist.mongo.MongoMessageStore.saveOrUpdate()

69
70
71
72
73
74
75
76
77
78
79
    message.setProperty("to", "3001111111");
    message.setProperty("from", "3542");
    message.setProperty("text", "this is a test");

    store.saveOrUpdate(message); // try to save the message

    Assert.assertNotNull(message.getId());

    DBCollection col = db.getCollection(MongoMessageStore.CONNECTIONS_MSGS);
    BasicDBObject obj = (BasicDBObject) col.findOne();
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
    message.setDestination("destination");
    message.setProperty("to", "3001111111");
    message.setProperty("from", "3542");
    message.setProperty("text", "this is a test");

    store.saveOrUpdate(message);

    Assert.assertNotNull(message.getId());

    DBCollection col = db.getCollection(MongoMessageStore.APPLICATIONS_MSGS);
    BasicDBObject obj = (BasicDBObject) col.findOne();
View Full Code Here
131
132
133
134
135
136
137
138
139
140
141
  public void shouldFailToSaveOrUpdateWithUnknownDirection() throws Exception {
    MongoMessageStore store = new MongoMessageStore();
    store.setMongo(db);

    Message message = new Message();
    store.saveOrUpdate(message);
  }

  @Test(expectedExceptions=IllegalArgumentException.class)
  public void shouldFailToSaveOrUpdateWithNullMessage() throws Exception {
    MongoMessageStore store = new MongoMessageStore();
View Full Code Here
139
140
141
142
143
144
145
146
147
148
149
  @Test(expectedExceptions=IllegalArgumentException.class)
  public void shouldFailToSaveOrUpdateWithNullMessage() throws Exception {
    MongoMessageStore store = new MongoMessageStore();
    store.setMongo(db);

    store.saveOrUpdate(null);
  }

  @SuppressWarnings("unchecked")
  @Test
  public void shouldUpdateConnectionMessage() throws Exception {
View Full Code Here
162
163
164
165
166
167
168
169
170
171
172
    message.setModificationTime(new Date());
    message.setProperty("to", "3002222222");
    message.setProperty("from", "2453");
    message.setProperty("text", "this is a test");

    store.saveOrUpdate(message);

    BasicDBObject obj = (BasicDBObject) col.findOne();

    Assert.assertNotNull(obj);
    Assert.assertEquals( (byte) obj.getInt("status"), Message.STATUS_CREATED );
View Full Code Here
200
201
202
203
204
205
206
207
208
209
210
    message.setModificationTime(new Date());
    message.setProperty("to", "3002222222");
    message.setProperty("from", "2453");
    message.setProperty("text", "this is a test");

    store.saveOrUpdate(message);

    BasicDBObject obj = (BasicDBObject) col.findOne();

    Assert.assertNotNull(obj);
    Assert.assertEquals( (byte) obj.getInt("status"), Message.STATUS_CREATED );
View Full Code Here
401
402
403
404
405
406
407
408
409
410
411
  }

  @Test(expectedExceptions=IllegalStateException.class)
  public void shouldFailSaveOrUpdateWithNullDB() throws Exception {
    MongoMessageStore store = new MongoMessageStore();
    store.saveOrUpdate(new Message());
  }

  @Test(expectedExceptions=IllegalStateException.class)
  public void shouldFailUpdateStatusWithNullDB() throws Exception {
    MongoMessageStore store = new MongoMessageStore();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.