Home
last modified time | relevance | path

Searched defs:topic (Results 1 – 25 of 125) sorted by relevance

12345

/external/sdk-platform-java/test/integration/goldens/pubsub/src/com/google/cloud/pubsub/v1/
DTopicAdminClientTest.java268 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in publishTest() local
292 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in publishExceptionTest() local
307 String topic = "topic110546223"; in publishTest2() local
331 String topic = "topic110546223"; in publishExceptionTest2() local
354 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in getTopicTest() local
376 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in getTopicExceptionTest() local
398 String topic = "topic110546223"; in getTopicTest2() local
420 String topic = "topic110546223"; in getTopicExceptionTest2() local
526 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in listTopicSubscriptionsTest() local
553 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in listTopicSubscriptionsExceptionTest() local
[all …]
DTopicAdminClient.java394 public final PublishResponse publish(TopicName topic, List<PubsubMessage> messages) { in publish()
427 public final PublishResponse publish(String topic, List<PubsubMessage> messages) { in publish()
512 public final Topic getTopic(TopicName topic) { in getTopic()
540 public final Topic getTopic(String topic) { in getTopic()
786 public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(TopicName topic) { in listTopicSubscriptions()
818 public final ListTopicSubscriptionsPagedResponse listTopicSubscriptions(String topic) { in listTopicSubscriptions()
957 public final ListTopicSnapshotsPagedResponse listTopicSnapshots(TopicName topic) { in listTopicSnapshots()
992 public final ListTopicSnapshotsPagedResponse listTopicSnapshots(String topic) { in listTopicSnapshots()
1138 public final void deleteTopic(TopicName topic) { in deleteTopic()
1169 public final void deleteTopic(String topic) { in deleteTopic()
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt/
DMqttMessage.java11 private String topic; field in MqttMessage
33 …public MqttMessage(String topic, byte[] payload, QualityOfService qos, boolean retain, boolean dup… in MqttMessage()
54 public MqttMessage(String topic, byte[] payload, QualityOfService qos, boolean retain) { in MqttMessage()
67 public MqttMessage(String topic, byte[] payload, QualityOfService qos) { in MqttMessage()
77 public MqttMessage(String topic, byte[] payload) { in MqttMessage()
DMqttClientConnection.java51 void deliver(String topic, byte[] payload, boolean dup, int qos, boolean retain) { in deliver()
350 …public CompletableFuture<Integer> subscribe(String topic, QualityOfService qos, Consumer<MqttMessa… in subscribe()
378 public CompletableFuture<Integer> subscribe(String topic, QualityOfService qos) { in subscribe()
398 public CompletableFuture<Integer> unsubscribe(String topic) { in unsubscribe()
487 … private static native short mqttClientConnectionSubscribe(long connection, String topic, int qos, in mqttClientConnectionSubscribe()
493 …private static native short mqttClientConnectionUnsubscribe(long connection, String topic, AsyncCa… in mqttClientConnectionUnsubscribe()
495 …private static native short mqttClientConnectionPublish(long connection, String topic, int qos, bo… in mqttClientConnectionPublish()
498 …private static native boolean mqttClientConnectionSetWill(long connection, String topic, int qos, … in mqttClientConnectionSetWill()
/external/sdk-platform-java/test/integration/goldens/pubsub/src/com/google/pubsub/v1/
DTopicName.java41 private final String topic; field in TopicName
83 public static TopicName of(String project, String topic) { in of()
88 public static TopicName ofProjectTopicName(String project, String topic) { in ofProjectTopicName()
97 public static String format(String project, String topic) { in format()
102 public static String formatProjectTopicName(String project, String topic) { in formatProjectTopicName()
201 private String topic; field in TopicName.Builder
218 public Builder setTopic(String topic) { in setTopic()
/external/google-cloud-java/java-notification/src/main/java/com/google/cloud/notification/
DNotificationInfo.java63 private final ProjectTopicName topic; field in NotificationInfo
74 private ProjectTopicName topic; field in NotificationInfo.Builder
82 Builder(ProjectTopicName topic) { in Builder()
107 public Builder setTopic(ProjectTopicName topic) { in setTopic()
260 public static NotificationInfo of(ProjectTopicName topic) { in of()
267 public static Builder newBuilder(ProjectTopicName topic) { in newBuilder()
/external/googleapis/google/cloud/pubsublite/v1/
Dtopic_stats.proto78 string topic = 1 [ field
119 string topic = 1 [ field
140 string topic = 1 [ field
/external/googleapis/google/pubsub/v1beta2/
Dpubsub.proto137 string topic = 1; field
143 string topic = 1; field
184 string topic = 1; field
209 string topic = 1; field
220 string topic = 2; field
/external/autotest/site_utils/
Dpubsub_utils_unittest.py31 def __init__(self, test, topic, msg, retry, ret_val=None, argument
48 def publish(self, topic, body): argument
/external/aws-crt-java/src/main/java/software/amazon/awssdk/crt/mqtt5/packets/
DPublishPacket.java23 private String topic; field in PublishPacket
286 private String topic; field in PublishPacket.PublishPacketBuilder
343 public PublishPacketBuilder withTopic(String topic) { in withTopic()
/external/sl4a/ScriptingLayerForAndroid/src/org/connectbot/
DHelpTopicActivity.java39 String topic = getIntent().getStringExtra(Intent.EXTRA_TITLE); in onCreate() local
DHelpActivity.java68 final String topic = name.substring(0, name.length() - SUFFIX.length()); in onCreate() local
/external/sdk-platform-java/test/integration/goldens/pubsub/samples/snippets/generated/main/java/com/google/cloud/pubsub/v1/publisher/listtopicsubscriptions/
DSyncListTopicSubscriptionsString.java36 String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); in syncListTopicSubscriptionsString() local
DSyncListTopicSubscriptionsTopicname.java36 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncListTopicSubscriptionsTopicname() local
/external/sdk-platform-java/test/integration/goldens/pubsub/samples/snippets/generated/main/java/com/google/cloud/pubsub/v1/publisher/deletetopic/
DSyncDeleteTopicTopicname.java37 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncDeleteTopicTopicname() local
DSyncDeleteTopicString.java37 String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); in syncDeleteTopicString() local
/external/sdk-platform-java/test/integration/goldens/pubsub/samples/snippets/generated/main/java/com/google/cloud/pubsub/v1/publisher/listtopicsnapshots/
DSyncListTopicSnapshotsString.java36 String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); in syncListTopicSnapshotsString() local
DSyncListTopicSnapshotsTopicname.java36 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncListTopicSnapshotsTopicname() local
/external/sdk-platform-java/test/integration/goldens/pubsub/samples/snippets/generated/main/java/com/google/cloud/pubsub/v1/publisher/gettopic/
DSyncGetTopicTopicname.java37 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncGetTopicTopicname() local
DSyncGetTopicString.java37 String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); in syncGetTopicString() local
/external/sdk-platform-java/test/integration/goldens/pubsub/samples/snippets/generated/main/java/com/google/cloud/pubsub/v1/publisher/publish/
DSyncPublishStringListpubsubmessage.java40 String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); in syncPublishStringListpubsubmessage() local
DSyncPublishTopicnameListpubsubmessage.java40 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncPublishTopicnameListpubsubmessage() local
/external/sdk-platform-java/test/integration/goldens/pubsub/samples/snippets/generated/main/java/com/google/cloud/pubsub/v1/subscriber/createsubscription/
DSyncCreateSubscriptionStringTopicnamePushconfigInt.java40 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncCreateSubscriptionStringTopicnamePushconfigInt() local
DSyncCreateSubscriptionStringStringPushconfigInt.java40 String topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]").toString(); in syncCreateSubscriptionStringStringPushconfigInt() local
DSyncCreateSubscriptionSubscriptionnameTopicnamePushconfigInt.java41 TopicName topic = TopicName.ofProjectTopicName("[PROJECT]", "[TOPIC]"); in syncCreateSubscriptionSubscriptionnameTopicnamePushconfigInt() local

12345