An important benefit for Real-Time API Management is the way in which it simplifies
development of applications. Modern applications often require multiple types of data
interactions -- event streams, direct messaging, and time series data are all leveraged
to deliver rich application experiences and functionality. Diffusion is a unified platform
to support multiple mechanisms for distributing data among systems, applications,
and devices; with security and management layers applied above all data flows.
Development teams who use Diffusion can focus on core business features, instead of
low-level transport concerns, which allows their organizations to quickly and easily
capitalize on existing or new data sources with significantly lower development costs
and go-to-market time.
"We made the right choice - Diffusion integration only took 2 weeks
and
the performance is great!"
- Brenock
Publish
session.topics.add('my-topic',diffusion.topics.TopicType.JSON);
var value = { foo : 'bar' };
var result = session.topicUpdate.set('my-topic', diffusion.datatypes.json(), value);
await session.TopicControl.AddTopicAsync( “my-topic”, TopicType.JSON );
var jsonDataType = Diffusion.DataTypes.JSON;
var value = jsonDataType.FromJSONString("{"foo": "bar"}");
var result = session.TopicUpdate.SetAsync(
"my-topic",
value);
session.feature(TopicControl.class).addTopic(
"my-topic",
TopicType.JSON,
new TopicControl.AddCallback.Default()); final JSONDataType jsonDataType = Diffusion.dataTypes()
.json();
final JSON value = jsonDataType.fromJsonString(
"{"foo" : "bar"}"); final CompletableFuture result = session.feature(TopicUpdate.class).set(
"my-topic", JSON.class, value);
self.session!.topicControl.add(
withTopicPath: "my-topic",
type: PTDiffusionTopicType.JSON,
value: nil,
completionHandler: self.errorHandler)
Now that the topic exists, you can publish data to it. Add the following lines:
var error: NSError? = nil
let value = PTDiffusionJSON(object: ["foo" : "bar" ], error: &error)
self.session!.topicUpdateControl.updater.update(
withTopicPath: "my-topic",
value: value,
completionHandler: self.errorHandler)
session.feature(TopicControl.class).addTopic("my-topic", TopicType.JSON);
final JSONDataType jsonDataType = Diffusion.dataTypes().json(); final JSON value = jsonDataType
.fromJsonString("{"foo" : "bar"}"); final CompletableFuture result = session.feature(
opicUpdate.class).set("my-topic", JSON.class, value)
We use cookies on our website to give you the most relevant experience by remembering your preferences and repeat visits. By clicking “Accept”, you consent to the use of ALL the cookies.Learn more
This website uses cookies to improve your experience while you navigate through the website. Out of these cookies, the cookies that are categorized as necessary are stored on your browser as they are essential for the working of basic functionalities of the website. We also use third-party cookies that help us analyze and understand how you use this website. These cookies will be stored in your browser only with your consent. You also have the option to opt-out of these cookies. But opting out of some of these cookies may have an effect on your browsing experience.
Necessary cookies are absolutely essential for the website to function properly. This category only includes cookies that ensures basic functionalities and security features of the website. These cookies do not store any personal information.
Any cookies that may not be particularly necessary for the website to function and is used specifically to collect user personal data via analytics, ads, other embedded contents are termed as non-necessary cookies. It is mandatory to procure user consent prior to running these cookies on your website.