SpringXD和Spring Integration:每隔X分钟从kafka主题中读取一遍,然后发送到另一个主题

我正在尝试实现一个解决方案来创建一个由kafka源,桥接模块和kafka接收器组成的SpringXD流。 所以我有类似的东西: 我的问题是我想以某种方式避免使用轮询器。 基本上是因为当这些消息在队列中时我想避免将消息保留在内存中。 我宁愿每隔X分钟从kafka读取一次,只需从队列中取出Y消息,然后将这些消息发送到下一个主题。 看起来我无法摆脱队列,但后来我的问题是:还有其他选择吗? 我不喜欢把东西留在内存中,但我也不想使用这个选项: http : //docs.spring.io/spring-integration/reference/html/system-management-chapter.html#message -商店

如何通过webdriver测试输入字段function的屏蔽

您好我想测试密码字段是否屏蔽了密码字段中输入的字符串。 我怎么能通过webdriver测试它。 我试过下面的事情: package unitTest.JUnitTestCases; import org.junit.Test; import org.openqa.selenium.By; import org.openqa.selenium.WebDriver; import org.openqa.selenium.WebElement; import org.openqa.selenium.firefox.FirefoxDriver; public class PasswordTest { @Test public void test() { WebDriver driver=new FirefoxDriver(); driver.manage().window().maximize(); driver.get(“http://docs.sencha.com/extjs/4.2.1/extjs-build/examples/form/adv-vtypes.html”); WebElement username=driver.findElement(By.id(“textfield-1014-inputEl”)); username.sendKeys(“admin”); System.out.println(username.getText()); WebElement password=driver.findElement(By.id(“textfield-1015-inputEl”)); password.sendKeys(“admin”); System.out.println(password.getAttribute(“textContent”)); //WebElement login=driver.findElement(By.id(“login”)); } } 在这里,我输入密码字段中的某个值,并尝试获取在该字段中输入的文本,以便我将检查它是否被屏蔽。 TIA!

Grails – 无法从Controller调用服务 – >总是得到“无法调用null对象上的方法错误”

我有一个grails应用程序,我在这里按照教程: http://www.grails.org/Services 我有一些代码 import org.springframework.beans.factory.InitializingBean class SubmitRequestService implements InitializingBean{ def GrailsApplication1 def setting void afterPropertiesSet(){ this.setting = GrailsApplication1.config.setting } def void sendHistoricalContract(HistoricalContract hc_instance){ //… blah blah whatever code } } class SubmitRequestController { def submitRequestService static allowedMethods = [save: “POST”, update: “POST”, delete: “POST”] def index = { // …. blah blah whatever code submitRequestService.sendHistoricalContract(historicalContractInstance) […]

与hibernate的父/子关系出现问题

我遇到了父子关系的问题。 Hibernate文档说在子类中添加“多对一”关系以从父级获取外键值。 但是为了使这种关系起作用,我必须在子类中添加Invoice属性,该子属性将父级循环包含在子级中并打破我的序列化程序。 有人可以指出我在哪里做错了吗? 这是我的代码: Invoice.java public class Invoice implements Serializable { private Long id; private Date invDate; private String customer; private Set items; … getters/setters … } InvoiceItem.java public class InvoiceItem implements Serializable { private Long itemId; private long productId; private int quantity; private double price; private Invoice invoice; //??????? … getters/setters … } […]

Android – Firebase – 获取子数据的子项

目标 通过Firebase数据库中的数据树获取当前用户的数据,如名称 , 地址 , 邻域 ,以提示他们的数据 数据树的图片 Desrciption 数据树中的“伦敦”和“华盛顿”子项由管理员帐户添加,这意味着它们不是固定的,并且可以添加其他子项,如“纽约”。 这意味着新编辑的数据树将在“用户”下,将有“伦敦”,“华盛顿”和“纽约” 其他孩子,如下面显示的那些孩子是固定的。 逆天 名称 邻里 警察 地址 名称 邻里 居民 地址 图片 名称 邻里 位置 状态 问题 尝试提示当前登录用户的数据后,我收到“java.lang.NullPointerException”。 错误显示在代码String stgUserHomeName = dataSnapshot.child(“Users”).getValue().toString(); 。 我之前能够获得我想要的数据,例如“姓名”,“地址”等,但是当我在“伦敦”和“华盛顿”这样的非固定父母中添加时,我遇到了问题。 SettingsActivity类 import android.content.Intent; import android.graphics.Bitmap; import android.net.Uri; import android.os.Bundle; import android.support.annotation.NonNull; import android.support.v7.app.AppCompatActivity; import android.support.v7.widget.Toolbar; import android.view.View; import android.widget.Button; import android.widget.ImageView; […]

inheritance尽管作文?

我通过Java World中的文章阅读了有关构图的一些内容: http : //www.javaworld.com/javaworld/jw-11-1998/jw-11-techniques.html?page = 1 在该文章中,它指导了如何在不使用extends关键字的情况下进行inheritance。 我这样做。 这可以吗? 它似乎对我有用。 这是代码: inheritance代码的例子:文章的第2页。\根据文章,它工作正常: class Fruit { public int peel() { System.out.println(“Peeling is appealing.”); return 1; } } class Apple extends Fruit { } class Example1 { public static void main(String[] args) { Apple apple = new Apple(); int pieces = apple.peel(); } } 修改后,它不再是好的: class […]

如何删除地图上标记上的阴影?

我在Google地图上显示自定义标记。 他们被安排得很好,但他们有这个有趣的阴影。 我怎样才能删除阴影? @Override public boolean draw(Canvas canvas, MapView mapView, boolean shadow, long when) { super.draw(canvas, mapView, shadow); // —translate the GeoPoint to screen pixels— Point screenPts = new Point(); mapView.getProjection().toPixels(geoPnt, screenPts); // —add the marker— /*Bitmap bmp = BitmapFactory.decodeResource(getResources(), R.drawable.pushpin); canvas.drawBitmap(bmp, screenPts.x, screenPts.y – 67, null);*/ return true; } }

考虑将序列化的java对象存储为cassandra作为JSON。 捕获量是多少?

我正在使用Cassandra 1.2.2。 我发现使用Jackson可以很容易地将我的对象映射到json和java之间以便存储在数据库中。 我实际上很想对我的所有数据这样做。 我的问题是,这是个好主意吗? 对我的应用程序执行此操作有什么缺点。 我的第一个猜测可能是更多的处理开销,但果汁值得挤压? 还有其他我需要知道的缺点吗?

Android相机效果不起作用

我正在尝试为Android构建一个图像编辑应用程序,我刚刚开始,我已经遇到了麻烦。 好吧,我可以拍照并保存到SD卡。 但我尝试做一些应用程序运行的效果,但效果不会出现在预览中。 下面是我使用的完整代码: package com.example.camerademo; import java.io.IOException; import android.app.Activity; import android.hardware.Camera; import android.os.Bundle; import android.view.SurfaceHolder; import android.view.SurfaceView; public class MainActivity extends Activity implements SurfaceHolder.Callback { SurfaceView cameraView; SurfaceHolder surfaceHolder; Camera camera; @Override public void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); cameraView = (SurfaceView) this.findViewById(R.id.CameraView); surfaceHolder = cameraView.getHolder(); surfaceHolder.setType(SurfaceHolder.SURFACE_TYPE_PUSH_BUFFERS); surfaceHolder.addCallback(this); } @Override public void surfaceChanged(SurfaceHolder holder, […]

使用不同SC系列探测智能卡:清除SC状态的命令

我希望从不同供应商,不同用途,不同APDU的一堆智能卡中读取一些基本信息。 例如:国家识别智能卡,EMV(支付),手机SIM,javacard等…… 我写了一个Java应用程序。 让我用SC系列ABCDE和相同名称调用5个子程序,每个子程序都有正确的APDU来读取一个特定SC系列的基本信息。 不幸的是,我发布例程的顺序会影响成功的结果。 示例:使用子程序ABCDE,我可以读取ABCD类型的SC,而不是E. 如果我将执行顺序更改为EABCD,我可以读取E但现在我的C类型的SC失败了。 我理解:一些SC丢弃外国APDU ……其他SC“挂起”。 是否有基本命令来清理智能卡(和读卡器)的状态? 那么子程序的执行顺序不会改变输出? 复位B复位C复位D复位等… 是ATR吗? 它对每种SC都是强制性的吗?