7.3. 创建共享订阅

  ClientOptions clientOptions = new ClientOptions();
  clientOptions.id("client-1");
  Client client = Client.Create(clientOptions);

  ReceiverOptions receiverOptions = new ReceiverOptions();
  receiverOptions.sourceOptions().capabilities("topic", "shared");
  receiverOptions.sourceOptions().durabilityMode(DurabilityMode.UNSETTLED_STATE);
  receiverOptions.sourceOptions().expiryPolicy(ExpiryPolicy.NEVER);
  Receiver receiver = connection.openDurableReceiver(address, "sub-1", receiverOptions);