anchor.diff:  			lists:keyfind("id", 1, BalanceList)
   	end.
   
  +notify_create_product() ->
  +	[{userdata, [{doc, "Receive product creation notification."}]}].
  +
  +notify_create_product(Config) ->
  +	HostUrl = ?config(host_url, Config),
  +	CollectionUrl = HostUrl ++ ?PathProductHub,
  +	ListenerPort = ?config(listener_port, Config),
  +	ListenerServer = "http://localhost:" ++ integer_to_list(ListenerPort),
  +	Callback = ListenerServer ++ "/listener/"
  +			++ atom_to_list(?MODULE) ++ "/notifycreateproduct",
  +	RequestBody = "{\n"
  +			++ "\t\"callback\": \"" ++ Callback ++ "\",\n"
  +			++ "}\n",
  +	ContentType = "application/json",
  +	Accept = {"accept", "application/json"},
  +	Request = {CollectionUrl, [Accept, auth_header()], ContentType, RequestBody},
  +	{ok, {{_, 201, _}, _, _}} = httpc:request(post, Request, [], []),
  +	Price = #price{name = ocs:generate_identity(),
  +			type = usage, units = octets, size = 1000, amount = 100},
  +	Offer = #offer{name = ocs:generate_identity(),
  +			price = [Price], specification = 4},
  +	{ok, #offer{name = OfferId}} = ocs:add_offer(Offer),
  +	{ok, #product{id = ProductId}} = ocs:add_product(OfferId, [], []),
  +	Product = receive
  +		Input ->
  +			{struct, ProductEvent} = mochijson:decode(Input),
  +			{_, "ResourceCreateEvent"}
  +					= lists:keyfind("eventType", 1, ProductEvent),
  +			{_, {struct, ProductList}} = lists:keyfind("event", 1, ProductEvent),
  +			ProductList
  +	end,
  +	{_, ProductId} = lists:keyfind("id", 1, Product),
  +	{_, OfferId} = lists:keyfind("product", 1, Product).
  +
   %%---------------------------------------------------------------------
   %%  Internal functions
   %%---------------------------------------------------------------------
  
positive.code: %% Initialization before each test case.
  %%
  init_per_testcase(TestCase, Config) when TestCase == notify_create_bucket;
  		TestCase == notify_delete_expired_bucket ->
  	true = register(TestCase, self()),
  	case inets:start(httpd, [{port, 0},
  			{server_name, atom_to_list(?MODULE)},
  
negative.code: %-define(MILLISECOND, millisecond).
  
  -define(PathBalanceHub, "/balanceManagement/v1/hub/").
  -define(PathProductHub, "/productInventoryManagement/v2/hub/").
  
  %%---------------------------------------------------------------------
  %%  Test server callback functions
  