diff options
Diffstat (limited to 'src/mod_offline_riak.erl')
| -rw-r--r-- | src/mod_offline_riak.erl | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/src/mod_offline_riak.erl b/src/mod_offline_riak.erl index 647f71dfd..241a8d650 100644 --- a/src/mod_offline_riak.erl +++ b/src/mod_offline_riak.erl @@ -36,9 +36,12 @@ store_messages(Host, {User, _}, Msgs, Len, MaxOfflineMsgs) -> try lists:foreach( fun(#offline_msg{us = US, + packet = Pkt, timestamp = TS} = M) -> + El = xmpp:encode(Pkt), ok = ejabberd_riak:put( - M, offline_msg_schema(), + M#offline_msg{packet = El}, + offline_msg_schema(), [{i, TS}, {'2i', [{<<"us">>, US}]}]) end, Msgs), {atomic, ok} @@ -85,9 +88,7 @@ read_message_headers(LUser, LServer) -> fun(#offline_msg{from = From, to = To, packet = Pkt, timestamp = TS}) -> Seq = now_to_integer(TS), - NewPkt = jlib:add_delay_info( - Pkt, LServer, TS, <<"Offline Storage">>), - {Seq, From, To, NewPkt} + {Seq, From, To, Pkt} end, Rs), lists:keysort(1, Hdrs); _Err -> |