anchor.diff:  			end_date = erlang:system_time(?MILLISECOND) + 2592000000},
   	{ok, _, #bucket{}} = ocs:add_bucket(ProdRef, Bucket),
   	Balance = receive
  -		Input2 ->
  -			{struct, BalanceEvent} = mochijson:decode(Input2),
  +		Input3 ->
  +			{struct, BalanceEvent} = mochijson:decode(Input3),
   			{_, "BucketBalanceCreationNotification"}
   					= lists:keyfind("eventType", 1, BalanceEvent),
   			{_, {struct, BalanceList}} = lists:keyfind("event", 1, BalanceEvent),
  
positive.code: 			undefined, ServiceId, Timestamp, undefined, undefined, initial,
  			[], [{octets, PackageSize}], SessionId),
  	AccBalanceStructs = receive
  		Input6 ->
  			{struct, AccBalanceEvent} = mochijson:decode(Input6),
  			{_, "AccumulatedBalanceCreationNotification"}
  					= lists:keyfind("eventType", 1, AccBalanceEvent),
  			{_, {array, AccStructList}}
  
negative.code: 	Price = #price{name = ocs:generate_identity(), start_date = SD,
  			type = recurring, period = monthly,
  			amount = Amount, alteration = Alteration},
  	OfferId = add_offer([Price], 4),
  	receive
  		Input1 ->
  			{struct, OfferEvent} = mochijson:decode(Input1),
  			{_, "ProductOfferingCreationNotification"}
  					= lists:keyfind("eventType", 1, OfferEvent)
  	end,
  	{ok, #product{id = ProdId} = P} = ocs:add_product(OfferId, []),
  	receive
  		Input2 ->
  			{struct, ProductEvent} = mochijson:decode(Input2),
  			{_, "ProductCreationNotification"}
  					= lists:keyfind("eventType", 1, ProductEvent),
  			{_, {struct, ProductList}} = lists:keyfind("event", 1, ProductEvent),
  