anchor.diff:  	post_hub_balance, delete_hub_balance, notify_create_bucket,
   	notify_delete_bucket, notify_rating_deleted_bucket,
   	notify_accumulated_balance, notify_accumulated_threshold,
  -	notify_query_bucket,
  +	query_bucket_notification,
   	post_hub_product, delete_hub_product, notify_create_product,
  -	notify_delete_product, notify_query_product, post_hub_service,
  +	notify_delete_product, query_product_notification, post_hub_service,
   	delete_hub_service,
  -	notify_create_service, notify_delete_service, notify_query_service,
  +	notify_create_service, notify_delete_service, query_service_notification,
   	post_hub_user, delete_hub_user, post_hub_catalog, delete_hub_catalog,
  -	notify_create_offer, notify_delete_offer, notify_query_offer,
  +	notify_create_offer, notify_delete_offer, query_offer_notification,
   	notify_insert_gtt, notify_delete_gtt, query_gtt_notification,
   	notify_add_pla, notify_delete_pla,
   	post_hub_inventory, delete_hub_inventory, notify_product_charge,
  
positive.code: 			= lists:keyfind(cents, #acc_balance.units, AccBalanceRecords),
  	RA1 < Threshold.
  
  notify_query_bucket() ->
  	[{userdata, [{doc, "Query bucket notification"}]}].
  
  notify_query_bucket(Config) ->
  	PackagePrice = 100,
  	PackageSize = 1000,
  	P1 = #price{name = ocs:generate_identity(), type = usage, units = octets,
  
negative.code: 	ListenerPort = ?config(listener_port, Config),
  	ListenerServer = "http://localhost:" ++ integer_to_list(ListenerPort),
  	Callback = ListenerServer ++ "/listener/"
  			++ atom_to_list(?MODULE) ++ "/querybucketnotification",
  	Query = "eventType=BucketBalanceDeletionEvent&id=" ++ BId1,
  	RequestBody = "{\n"
  			++ "\t\"callback\": \"" ++ Callback ++ "\",\n"
  