Merge branch 'master' of git://github.com/synrc/kvs

src/kvs_account.erl

@@ -45,8 +45,9 @@ check_quota(User, Amount) ->
 
 commit_transaction(#transaction{remitter = R, acceptor = A,  currency = Currency, amount = Amount} = TX) ->
     case change_accounts(R, A, Currency, Amount) of
-         ok -> mqs:notify([kvs_account, user, R, transaction], TX),
-               mqs:notify([kvs_account, user, A, transaction], TX);
+         ok -> %mqs:notify([kvs_account, user, R, transaction], TX),
+               %mqs:notify([kvs_account, user, A, transaction], TX);
+                xen;
          Error -> skip end.
 
 check_remitter_balance(RA, Amount) -> ok.

src/kvs_group.erl

@@ -23,8 +23,8 @@ create(Creator, GroupName, GroupFullName, Desc, Publicity) ->
     Group = #group{id = GroupName, name = GroupFullName, description = Desc, scope = Publicity,
                    creator = Creator, created = Time, owner = Creator, feed = Feed},
     kvs:put(Group),
-    init_mq(Group),
-    mqs:notify([group, init], {GroupName, Feed}),
+%    init_mq(Group),
+%    mqs:notify([group, init], {GroupName, Feed}),
     add(Creator, GroupName, member),
     GroupName.
 
@@ -33,7 +33,7 @@ delete(GroupName) ->
     case kvs:get(group,GroupName) of 
         {error,_} -> ok;
         {ok, Group} ->
-            mqs:notify([feed, delete, GroupName], empty),
+%            mqs:notify([feed, delete, GroupName], empty),
             kvs:delete_by_index(group_subscription, <<"where_bin">>, GroupName),
             kvs:delete(feed, Group#group.feed),
             kvs:delete(group, GroupName),