Java SignalServiceSyncMessage类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage类的典型用法代码示例。如果您正苦于以下问题：Java SignalServiceSyncMessage类的具体用法？Java SignalServiceSyncMessage怎么用？Java SignalServiceSyncMessage使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

SignalServiceSyncMessage类属于org.whispersystems.signalservice.api.messages.multidevice包，在下文中一共展示了SignalServiceSyncMessage类的13个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: onRun

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
@Override
public void onRun(MasterSecret masterSecret)
    throws IOException, UntrustedIdentityException
{
  RecipientPreferenceDatabase database      = DatabaseFactory.getRecipientPreferenceDatabase(context);
  SignalServiceMessageSender  messageSender = messageSenderFactory.create();
  BlockedReader               reader        = database.readerForBlocked(database.getBlocked());
  List<String>                blocked       = new LinkedList<>();

  Recipients recipients;

  while ((recipients = reader.getNext()) != null) {
    if (recipients.isSingleRecipient()) {
      try {
        blocked.add(Util.canonicalizeNumber(context, recipients.getPrimaryRecipient().getNumber()));
      } catch (InvalidNumberException e) {
        Log.w(TAG, e);
      }
    }
  }

  messageSender.sendMessage(SignalServiceSyncMessage.forBlocked(new BlockedListMessage(blocked)));
}

开发者ID:XecureIT，项目名称:PeSanKita-android，代码行数:24，代码来源:MultiDeviceBlockedUpdateJob.java

示例2: sendUpdate

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
private void sendUpdate(SignalServiceMessageSender messageSender, File contactsFile)
    throws IOException, UntrustedIdentityException, NetworkException
{
  if (contactsFile.length() > 0) {
    FileInputStream               contactsFileStream = new FileInputStream(contactsFile);
    SignalServiceAttachmentStream attachmentStream   = SignalServiceAttachment.newStreamBuilder()
                                                                              .withStream(contactsFileStream)
                                                                              .withContentType("application/octet-stream")
                                                                              .withLength(contactsFile.length())
                                                                              .build();

    try {
      messageSender.sendMessage(SignalServiceSyncMessage.forContacts(attachmentStream));
    } catch (IOException ioe) {
      throw new NetworkException(ioe);
    }
  }
}

开发者ID:XecureIT，项目名称:PeSanKita-android，代码行数:19，代码来源:MultiDeviceContactUpdateJob.java

示例3: onRun

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
@Override
public void onRun(MasterSecret masterSecret) throws IOException, UntrustedIdentityException {
  if (!TextSecurePreferences.isMultiDevice(context)) {
    Log.w(TAG, "Not multi device...");
    return;
  }

  List<ReadMessage> readMessages = new LinkedList<>();

  for (SerializableSyncMessageId messageId : messageIds) {
    readMessages.add(new ReadMessage(messageId.sender, messageId.timestamp));
  }

  SignalServiceMessageSender messageSender = messageSenderFactory.create();
  messageSender.sendMessage(SignalServiceSyncMessage.forRead(readMessages));
}

开发者ID:XecureIT，项目名称:PeSanKita-android，代码行数:17，代码来源:MultiDeviceReadUpdateJob.java

示例4: sendMessage

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
public void sendMessage(SignalServiceSyncMessage message)
    throws IOException, UntrustedIdentityException
{
  byte[] content;

  if (message.getContacts().isPresent()) {
    content = createMultiDeviceContactsContent(message.getContacts().get().asStream());
  } else if (message.getGroups().isPresent()) {
    content = createMultiDeviceGroupsContent(message.getGroups().get().asStream());
  } else if (message.getRead().isPresent()) {
    content = createMultiDeviceReadContent(message.getRead().get());
  } else if (message.getBlockedList().isPresent()) {
    content = createMultiDeviceBlockedContent(message.getBlockedList().get());
  } else {
    throw new IOException("Unsupported sync message!");
  }

  sendMessage(localAddress, System.currentTimeMillis(), content, false, false);
}

开发者ID:XecureIT，项目名称:PeSanKita-lib，代码行数:20，代码来源:SignalServiceMessageSender.java

示例5: createSynchronizeMessage

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
private SignalServiceSyncMessage createSynchronizeMessage(SignalServiceEnvelope envelope, SyncMessage content) {
  if (content.hasSent()) {
    SyncMessage.Sent sentContent = content.getSent();
    return SignalServiceSyncMessage.forSentTranscript(new SentTranscriptMessage(sentContent.getDestination(),
                                                                                sentContent.getTimestamp(),
                                                                                createSignalServiceMessage(envelope, sentContent.getMessage()),
                                                                                sentContent.getExpirationStartTimestamp()));
  }

  if (content.hasRequest()) {
    return SignalServiceSyncMessage.forRequest(new RequestMessage(content.getRequest()));
  }

  if (content.getReadList().size() > 0) {
    List<ReadMessage> readMessages = new LinkedList<>();

    for (SyncMessage.Read read : content.getReadList()) {
      readMessages.add(new ReadMessage(read.getSender(), read.getTimestamp()));
    }

    return SignalServiceSyncMessage.forRead(readMessages);
  }

  return SignalServiceSyncMessage.empty();
}

开发者ID:XecureIT，项目名称:PeSanKita-lib，代码行数:26，代码来源:SignalServiceCipher.java

示例6: onRun

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
@Override
public void onRun() throws IOException, UntrustedIdentityException {
  try {
    if (!TextSecurePreferences.isMultiDevice(context)) {
      Log.w(TAG, "Not multi device...");
      return;
    }

    if (destination == null) {
      Log.w(TAG, "No destination...");
      return;
    }

    String                        canonicalDestination = Util.canonicalizeNumber(context, destination);
    VerifiedMessage.VerifiedState verifiedState        = getVerifiedState(verifiedStatus);
    SignalServiceMessageSender    messageSender        = messageSenderFactory.create();
    VerifiedMessage               verifiedMessage      = new VerifiedMessage(canonicalDestination, new IdentityKey(identityKey, 0), verifiedState, timestamp);

    messageSender.sendMessage(SignalServiceSyncMessage.forVerified(verifiedMessage));
  } catch (InvalidNumberException | InvalidKeyException e) {
    throw new IOException(e);
  }
}

开发者ID:CableIM，项目名称:Cable-Android，代码行数:24，代码来源:MultiDeviceVerifiedUpdateJob.java

示例7: sendUpdate

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
private void sendUpdate(SignalServiceMessageSender messageSender, File contactsFile, boolean complete)
    throws IOException, UntrustedIdentityException, NetworkException
{
  if (contactsFile.length() > 0) {
    FileInputStream               contactsFileStream = new FileInputStream(contactsFile);
    SignalServiceAttachmentStream attachmentStream   = SignalServiceAttachment.newStreamBuilder()
                                                                              .withStream(contactsFileStream)
                                                                              .withContentType("application/octet-stream")
                                                                              .withLength(contactsFile.length())
                                                                              .build();

    try {
      messageSender.sendMessage(SignalServiceSyncMessage.forContacts(new ContactsMessage(attachmentStream, complete)));
    } catch (IOException ioe) {
      throw new NetworkException(ioe);
    }
  }
}

开发者ID:CableIM，项目名称:Cable-Android，代码行数:19，代码来源:MultiDeviceContactUpdateJob.java

示例8: sendUpdate

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
private void sendUpdate(SignalServiceMessageSender messageSender, File contactsFile)
    throws IOException, UntrustedIdentityException
{
  FileInputStream               contactsFileStream = new FileInputStream(contactsFile);
  SignalServiceAttachmentStream attachmentStream   = SignalServiceAttachment.newStreamBuilder()
                                                                            .withStream(contactsFileStream)
                                                                            .withContentType("application/octet-stream")
                                                                            .withLength(contactsFile.length())
                                                                            .build();

  messageSender.sendMessage(SignalServiceSyncMessage.forGroups(attachmentStream));
}

开发者ID:XecureIT，项目名称:PeSanKita-android，代码行数:13，代码来源:MultiDeviceGroupUpdateJob.java

示例9: markRead

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
/**
 * Notify other devices that these messages have been read.
 * @param messages
 * @throws IOException
 */
public void markRead(List<ReadMessage> messages) throws IOException {
	checkRegistered();
	checkMessageSender();
	try {
		SignalServiceSyncMessage syncMessage = SignalServiceSyncMessage.forRead(messages);
		messageSender.sendMessage(syncMessage);
	} catch (UntrustedIdentityException e) {
		fireSecurityException(new SignalServiceAddress(store.getPhoneNumber()), e);
	}
}

开发者ID:Turakar，项目名称:signal4j，代码行数:16，代码来源:SignalService.java

示例10: requestSync

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
/**
 * Request sync messages from primary device. They are received using the listeners
 * @throws IOException
 * @throws UntrustedIdentityException
 */
public void requestSync() throws IOException {
	try {
		checkRegistered();
		checkMessageSender();
		Request.Type[] types = new Request.Type[] {Request.Type.CONTACTS, Request.Type.GROUPS, Request.Type.BLOCKED};
		for(Request.Type type : types) {
			RequestMessage request = new RequestMessage(Request.newBuilder().setType(type).build());
			SignalServiceSyncMessage syncMessage = SignalServiceSyncMessage.forRequest(request);
			messageSender.sendMessage(syncMessage);
		}
	} catch(UntrustedIdentityException e) {
		fireSecurityException(new SignalServiceAddress(store.getPhoneNumber()), e);
	}
}

开发者ID:Turakar，项目名称:signal4j，代码行数:20，代码来源:SignalService.java

示例11: JsonSyncMessage

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
JsonSyncMessage(SignalServiceSyncMessage syncMessage) {
    if (syncMessage.getSent().isPresent()) {
        this.sentMessage = new JsonDataMessage(syncMessage.getSent().get().getMessage());
    }
    if (syncMessage.getBlockedList().isPresent()) {
        this.blockedNumbers = syncMessage.getBlockedList().get().getNumbers();
    }
    if (syncMessage.getRead().isPresent()) {
        this.readMessages = syncMessage.getRead().get();
    }
}

开发者ID:AsamK，项目名称:signal-cli，代码行数:12，代码来源:JsonSyncMessage.java

示例12: SignalServiceContent

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
public SignalServiceContent(SignalServiceSyncMessage synchronizeMessage) {
  this.message            = Optional.absent();
  this.synchronizeMessage = Optional.fromNullable(synchronizeMessage);
  this.callMessage        = Optional.absent();
}

开发者ID:XecureIT，项目名称:PeSanKita-lib，代码行数:6，代码来源:SignalServiceContent.java

示例13: getSyncMessage

import org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage; //导入依赖的package包/类
public Optional<SignalServiceSyncMessage> getSyncMessage() {
  return synchronizeMessage;
}

开发者ID:XecureIT，项目名称:PeSanKita-lib，代码行数:4，代码来源:SignalServiceContent.java

注：本文中的org.whispersystems.signalservice.api.messages.multidevice.SignalServiceSyncMessage类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java ServerConstants类代码示例发布时间：2022-05-23

Java DatasetWriter类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18904|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9898|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8294|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8653|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8586|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9593|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8578|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7967|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8586|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7508|2022-11-06

客服电话

电子邮件

Java SignalServiceSyncMessage类代码示例

示例1: onRun

示例2: sendUpdate

示例3: onRun

示例4: sendMessage

示例5: createSynchronizeMessage

示例6: onRun

示例7: sendUpdate

示例8: sendUpdate

示例9: markRead

示例10: requestSync

示例11: JsonSyncMessage

示例12: SignalServiceContent

示例13: getSyncMessage

请发表评论

全部评论

上一篇：

下一篇：

CVE-2022-1794

librespeed/speedtest: Self-hosted Speedt

edenhill/librdkafka: The Apache Kafka C/

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053